com.ibm.ims.jms

Class IMSQueueConnectionFactory

java.lang.Object

com.ibm.ims.jms.IMSQueueConnectionFactory

All Implemented Interfaces:

javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory

public class IMSQueueConnectionFactory
extends java.lang.Object
implements javax.jms.QueueConnectionFactory

Factory class used to create IMS Point-to-Point messaging domain QueueConnection objects.

The following code fragment shows how to use IMSQueueConnectionFactory to obtain and use a QueueConnection object.

 IMSQueueConnectionFactory jmsConnectionFactory = new IMSQueueConnectionFactory();
 QueueConnection jmsConnection = null;
 QueueSession jmsQueueSession = null;
 Queue jmsQueue = null;
 QueueRequestor jmsQueueRequestor = null;
        
 try {
     jmsConnectionFactory.setTimeout(1000);    //Set 10 second timeout
     jmsConnectionFactory.setResponseAreaLength(128000);    //Allocate 128K response area
     jmsConnection = jmsConnectionFactory.createQueueConnection();
     jmsQueueSession = jmsConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
     jmsQueue = jmsQueueSession.createQueue("OTMDEST1");
           
     jmsQueueRequestor = new QueueRequestor(jmsQueueSession, jmsQueue);
     TextMessage sendMsg = jmsQueueSession.createTextMessage();
           
     String msg = "My Message";
     sendMsg.setText(msg);
     TextMessage replyMsg = (TextMessage)jmsQueueRequestor.request(sendMsg);
     System.out.println("Received message: "+replyMsg.getText());
 } catch (Exception e) {
     e.printStackTrace();
 }

 

Constructor Summary

Constructors

Constructor and Description
IMSQueueConnectionFactory()

Method Summary

Modifier and Type	Method and Description
javax.jms.Connection	createConnection()
javax.jms.Connection	createConnection(java.lang.String arg0, java.lang.String arg1)
javax.jms.QueueConnection	createQueueConnection()
javax.jms.QueueConnection	createQueueConnection(java.lang.String arg0, java.lang.String arg1)
int	getResponseAreaLength()
int	getTimeout()
void	setResponseAreaLength(int responseAreaLength) Sets the responseAreaLength value.
void	setTimeout(int timeout) Sets the timeout value.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IMSQueueConnectionFactory

public IMSQueueConnectionFactory()

Method Detail

createQueueConnection

public javax.jms.QueueConnection createQueueConnection()
                                                throws javax.jms.JMSException

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Throws:

javax.jms.JMSException

createQueueConnection

public javax.jms.QueueConnection createQueueConnection(java.lang.String arg0,
                                                       java.lang.String arg1)
                                                throws javax.jms.JMSException

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Throws:

javax.jms.JMSException

createConnection

public javax.jms.Connection createConnection()
                                      throws javax.jms.JMSException

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Throws:

javax.jms.JMSException

createConnection

public javax.jms.Connection createConnection(java.lang.String arg0,
                                             java.lang.String arg1)
                                      throws javax.jms.JMSException

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Throws:

javax.jms.JMSException

setTimeout

public void setTimeout(int timeout)
                throws javax.jms.JMSException

Sets the timeout value. This value represents the number of 0.01 second units to wait for a response.

By default, the value is set in the OTMA descriptor. If the value is set here to zero it will automatically be changed to 1000, which indicates a 10 second timeout value. The range of acceptable values is 0 - 999999.

Parameters:

timeout -

Throws:

javax.jms.JMSException

setResponseAreaLength

public void setResponseAreaLength(int responseAreaLength)
                           throws javax.jms.JMSException

Sets the responseAreaLength value. This value represents the size of the byte array that you want to have allocated to hold the response byte stream.

Parameters:

responseAreaLength -

Throws:

javax.jms.JMSException

getResponseAreaLength

public int getResponseAreaLength()

getTimeout

public int getTimeout()