com.pcbsys.nirvana.nJMS.QueueSessionImpl Class Reference

A QueueSession object provides methods for creating QueueReceiver, QueueSender, QueueBrowser, and TemporaryQueue objects. More...

Inherits com.pcbsys.nirvana.nJMS.SessionImpl, and QueueSession.

Public Member Functions

javax.jms.QueueBrowser createBrowser (javax.jms.Queue queue) throws javax.jms.JMSException, javax.jms.InvalidDestinationException
 <Enter Method Description> More...
 
javax.jms.QueueBrowser createBrowser (javax.jms.Queue queue, String messageSelector) throws javax.jms.JMSException, javax.jms.InvalidDestinationException, javax.jms.InvalidSelectorException
 <Enter Method Description> More...
 
javax.jms.QueueReceiver createReceiver (javax.jms.Queue queue) throws javax.jms.JMSException, javax.jms.InvalidDestinationException
 <Enter Method Description> More...
 
javax.jms.QueueReceiver createReceiver (javax.jms.Queue queue, String messageSelector) throws javax.jms.JMSException, javax.jms.InvalidDestinationException, javax.jms.InvalidSelectorException
 <Enter Method Description> More...
 
javax.jms.QueueSender createSender (javax.jms.Queue queue) throws javax.jms.JMSException, javax.jms.InvalidDestinationException
 <Enter Method Description> More...
 
 QueueSessionImpl ()
 <Enter Constructor Description>
 
- Public Member Functions inherited from com.pcbsys.nirvana.nJMS.SessionImpl
javax.jms.BytesMessage createBytesMessage () throws javax.jms.JMSException
 <Enter Method Description> More...
 
MessageConsumer createDurableConsumer (Topic topic, String name, String messageSelector, boolean noLocal) throws javax.jms.JMSException
 This method check specific newly introduced JMS 2.0 restrictions. More...
 
MessageConsumer createDurableConsumer (Topic topic, String name) throws javax.jms.JMSException
 Creates an unshared durable subscription on the specified topic (if one does not already exist) and creates a consumer on that durable subscription. More...
 
javax.jms.TopicSubscriber createDurableSubscriber (javax.jms.Topic topic, String name, String messageSelector, boolean NoLocal) throws javax.jms.JMSException, javax.jms.InvalidDestinationException, javax.jms.InvalidSelectorException
 This method creates durable subscription on specified topic. More...
 
javax.jms.MapMessage createMapMessage () throws javax.jms.JMSException
 <Enter Method Description> More...
 
javax.jms.Message createMessage () throws javax.jms.JMSException
 <Enter Method Description> More...
 
javax.jms.ObjectMessage createObjectMessage () throws javax.jms.JMSException
 <Enter Method Description> More...
 
javax.jms.ObjectMessage createObjectMessage (java.io.Serializable object) throws javax.jms.JMSException
 <Enter Method Description> More...
 
javax.jms.TopicPublisher createPublisher (javax.jms.Topic topic) throws javax.jms.JMSException, javax.jms.InvalidDestinationException
 <Enter Method Description> More...
 
javax.jms.QueueReceiver createReceiver (javax.jms.Queue queue, String messageSelector) throws javax.jms.JMSException, javax.jms.InvalidDestinationException, javax.jms.InvalidSelectorException
 <Enter Method Description> More...
 
javax.jms.QueueSender createSender (javax.jms.Queue queue) throws javax.jms.JMSException, javax.jms.InvalidDestinationException
 <Enter Method Description> More...
 
MessageConsumer createSharedConsumer (Topic topic, String sharedSubscriptionName) throws javax.jms.JMSException
 Creates a shared non-durable subscription with the specified name on the specified topic (if one does not already exist) and creates a consumer on that subscription. More...
 
MessageConsumer createSharedConsumer (Topic topic, String sharedSubscriptionName, String messageSelector) throws javax.jms.JMSException
 Creates a shared non-durable subscription with the specified name on the specified topic (if one does not already exist) specifying a message selector, and creates a consumer on that subscription. More...
 
MessageConsumer createSharedDurableConsumer (Topic topic, String name, String messageSelector) throws javax.jms.JMSException
 Creates a shared durable subscription on the specified topic (if one does not already exist), specifying a message selector, and creates a consumer on that durable subscription. More...
 
MessageConsumer createSharedDurableConsumer (Topic topic, String name) throws javax.jms.JMSException
 Creates a shared durable subscription on the specified topic (if one does not already exist), specifying a message selector and the. More...
 
javax.jms.StreamMessage createStreamMessage () throws javax.jms.JMSException
 <Enter Method Description> More...
 
javax.jms.TopicSubscriber createSubscriber (javax.jms.Topic topic) throws javax.jms.JMSException, javax.jms.InvalidDestinationException
 <Enter Method Description> More...
 
javax.jms.TextMessage createTextMessage () throws javax.jms.JMSException
 <Enter Method Description> More...
 
javax.jms.TextMessage createTextMessage (StringBuffer stringBuffer) throws javax.jms.JMSException
 <Enter Method Description> More...
 
void run ()
 Dispatches the message(s) to the MDB in a server provided thread (or to whatever in whatever thread provided by external platform. More...
 

Detailed Description

A QueueSession object provides methods for creating QueueReceiver, QueueSender, QueueBrowser, and TemporaryQueue objects.

If there are messages that have been received but not acknowledged when a QueueSession terminates, these messages will be retained and redelivered when a consumer next accesses the queue. A QueueSession is used for creating Point-to-Point specific objects. In general, use the Session object. The QueueSession is used to support existing code. Using the Session object simplifies the programming model, and allows transactions to be used across the two messaging domains. A QueueSession cannot be used to create objects specific to the publish/subscribe domain.

The following methods inherit from Session, but must throw an IllegalStateException if they are used from QueueSession: createDurableSubscriber createDurableConsumer createSharedConsumer createSharedDurableConsumer createTemporaryTopic createTopic unsubscribe

Member Function Documentation

javax.jms.QueueBrowser com.pcbsys.nirvana.nJMS.QueueSessionImpl.createBrowser ( javax.jms.Queue  queue) throws javax.jms.JMSException, javax.jms.InvalidDestinationException

<Enter Method Description>

Parameters
queue<Enter Parameter Description>
Returns
<Enter Result Description>
Exceptions
JMSException<Enter Exception Description>
javax.jms.QueueBrowser com.pcbsys.nirvana.nJMS.QueueSessionImpl.createBrowser ( javax.jms.Queue  queue,
String  messageSelector 
) throws javax.jms.JMSException, javax.jms.InvalidDestinationException, javax.jms.InvalidSelectorException

<Enter Method Description>

Parameters
queue<Enter Parameter Description>
messageSelector<Enter Parameter Description>
Returns
<Enter Result Description>
Exceptions
JMSException<Enter Exception Description>
javax.jms.QueueReceiver com.pcbsys.nirvana.nJMS.QueueSessionImpl.createReceiver ( javax.jms.Queue  queue) throws javax.jms.JMSException, javax.jms.InvalidDestinationException

<Enter Method Description>

Parameters
queue<Enter Parameter Description>
Returns
<Enter Result Description>
Exceptions
JMSException<Enter Exception Description>
javax.jms.QueueReceiver com.pcbsys.nirvana.nJMS.QueueSessionImpl.createReceiver ( javax.jms.Queue  queue,
String  messageSelector 
) throws javax.jms.JMSException, javax.jms.InvalidDestinationException, javax.jms.InvalidSelectorException

<Enter Method Description>

Parameters
queue<Enter Parameter Description>
messageSelector<Enter Parameter Description>
Returns
<Enter Result Description>
Exceptions
JMSException<Enter Exception Description>
javax.jms.QueueSender com.pcbsys.nirvana.nJMS.QueueSessionImpl.createSender ( javax.jms.Queue  queue) throws javax.jms.JMSException, javax.jms.InvalidDestinationException

<Enter Method Description>

Parameters
queue<Enter Parameter Description>
Returns
<Enter Result Description>
Exceptions
JMSException<Enter Exception Description>