com.ibm.mq.jms
Class MQQueueSession

java.lang.Object
  |
  +--com.ibm.mq.jms.MQSession
        |
        +--com.ibm.mq.jms.MQQueueSession
All Implemented Interfaces:
JMSAcknowledgePoint, JMSDestinationFactory, javax.jms.QueueSession, java.lang.Runnable, javax.jms.Session

public class MQQueueSession
extends MQSession
implements javax.jms.QueueSession

An MQQueueSession provides methods to create MQQueueReceivers, MQQueueSenders, MQQueueBrowsers, and MQTemporaryQueues.


Field Summary
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
     
Method Summary
 void commit()
          Commits all messages done in this transaction and releases any locks currently held.
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest)
          Creates a MessageConsumer for the specified Destination.
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest, java.lang.String sel)
          Creates a MessageConsumer for the specified Destination, using a message selector.
 javax.jms.MessageProducer createProducer(javax.jms.Destination dest)
          Creates a MessageProducer to send messages to the specified destination.
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
          Creates a QueueReceiver object to receive messages from the specified queue.
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String messageSelector)
          Creates an MQQueueReceiver object to receive messages from the specified queue and message selector.
 javax.jms.QueueSender createSender(javax.jms.Queue queue)
          Creates a QueueSender object to send messages to the specified queue.
 javax.jms.TemporaryQueue createTemporaryQueue()
          Creates a JMS temporary queue.
 void recover()
          Restarts message delivery from the oldest unacknowledged message.
 void rollback()
          Rolls back any messages done in this transaction and releases any locks currently held.
 
Methods inherited from class com.ibm.mq.jms.MQSession
close, createBrowser, createBrowser, createBytesMessage, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createQueue, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, setMessageListener
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface javax.jms.QueueSession
createBrowser, createBrowser, createQueue
 
Methods inherited from interface javax.jms.Session
close, createBytesMessage, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, run, setMessageListener
 

Method Detail

commit

public void commit()
            throws javax.jms.JMSException
Description copied from class: MQSession
Commits all messages done in this transaction and releases any locks currently held. This always throws a JMSException when you have a direct connection to WebSphere MQ Event Broker.

Specified by:
commit in interface javax.jms.Session
Overrides:
commit in class MQSession
Throws:
javax.jms.JMSException - with one of the following reasons:

rollback

public void rollback()
              throws javax.jms.JMSException
Rolls back any messages done in this transaction and releases any locks currently held.

Specified by:
rollback in interface javax.jms.Session
Overrides:
rollback in class MQSession
Throws:
javax.jms.JMSException - if JMS implementation fails to roll back the the transaction due to some internal error.

recover

public void recover()
             throws javax.jms.JMSException
Restarts message delivery from the oldest unacknowledged message. Analagous to rollback(), but for the non-transacted case.

Specified by:
recover in interface javax.jms.Session
Overrides:
recover in class MQSession
Throws:
javax.jms.JMSException - with one of the following reasons:

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.JMSException
Creates a QueueSender object to send messages to the specified queue.

Specified by:
createSender in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException
Creates a QueueReceiver object to receive messages from the specified queue.

Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
                                              java.lang.String messageSelector)
                                       throws javax.jms.JMSException
Creates an MQQueueReceiver object to receive messages from the specified queue and message selector.

Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.JMSException

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException
Description copied from class: MQSession
Creates a JMS temporary queue. The temporary queue remains until the connection ends or the queue is explicitly deleted, whichever is the sooner.

Specified by:
createTemporaryQueue in interface javax.jms.QueueSession
Overrides:
createTemporaryQueue in class MQSession
Returns:
TemporaryQueue
Throws:
javax.jms.JMSException - IllegalStateException with one of the following reasons:

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest)
                                         throws javax.jms.JMSException
Description copied from class: MQSession
Creates a MessageConsumer for the specified Destination. Since Queue and Topic both inherit from Destination, they can be used in the destination parameter to create a MessageConsumer.

Specified by:
createConsumer in interface javax.jms.Session
Overrides:
createConsumer in class MQSession
Parameters:
dest - the Destination to access.
Returns:
the message consumer
Throws:
javax.jms.JMSException - if the command fails due to some internal JMS error.

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest,
                                                java.lang.String sel)
                                         throws javax.jms.JMSException
Description copied from class: MQSession
Creates a MessageConsumer for the specified Destination, using a message selector.

Specified by:
createConsumer in interface javax.jms.Session
Overrides:
createConsumer in class MQSession
Parameters:
dest - the Destination to access.
sel - the message selector
Returns:
the message consumer.
Throws:
javax.jms.JMSException - if the command fails due to some internal JMS error.

createProducer

public javax.jms.MessageProducer createProducer(javax.jms.Destination dest)
                                         throws javax.jms.JMSException
Description copied from class: MQSession
Creates a MessageProducer to send messages to the specified destination.

Specified by:
createProducer in interface javax.jms.Session
Overrides:
createProducer in class MQSession
Parameters:
dest - the Destination to send to, or null if this is a producer which does not have a specified destination.
Throws:
javax.jms.JMSException - with reason MQJMS_EXCEPTION_MQ_NULL_QMGR

(c) Copyright IBM Corp. 2005. All Rights Reserved.