org.skyscreamer.nevado.jms

Class NevadoTopicSession

java.lang.Object

org.skyscreamer.nevado.jms.NevadoSession

org.skyscreamer.nevado.jms.NevadoTopicSession

All Implemented Interfaces:

Runnable, javax.jms.Session, javax.jms.TopicSession

public class NevadoTopicSession
extends NevadoSession
implements javax.jms.TopicSession

Nevado implementation of TopicSession

Author:

Carter Page

Field Summary

Fields inherited from class org.skyscreamer.nevado.jms.NevadoSession

_closed

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	NevadoTopicSession(NevadoConnection connection, boolean transacted, int acknowledgeMode)

Method Summary

Methods

Modifier and Type	Method and Description
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue)
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue, String s)
NevadoMessageConsumer	createConsumer(javax.jms.Destination destination)
NevadoMessageConsumer	createConsumer(javax.jms.Destination destination, String selector)
NevadoMessageConsumer	createConsumer(javax.jms.Destination destination, String selector, boolean noLocal)
NevadoMessageProducer	createProducer(javax.jms.Destination destination)
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
NevadoQueue	createQueue(String s)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, String selector, boolean noLocal)
NevadoTemporaryQueue	createTemporaryQueue()

Methods inherited from class org.skyscreamer.nevado.jms.NevadoSession

acknowledgeMessage, checkClosed, close, commit, createBytesMessage, createDurableSubscriber, createDurableSubscriber, createInternalQueue, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, deleteMessage, expireMessage, getAcknowledgeMode, getConnection, getDurableEndpointQueueName, getMessageListener, getTransacted, isClosed, receiveMessage, recover, resetMessage, rollback, run, sendMessage, setBreakSessionForTesting, setMessageListener, setOverrideJMSDeliveryMode, setOverrideJMSPriority, setOverrideJMSTTL, start, stop, unsubscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.TopicSession

createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe

Methods inherited from interface javax.jms.Session

close, commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener

Constructor Detail

NevadoTopicSession

protected NevadoTopicSession(NevadoConnection connection,
                  boolean transacted,
                  int acknowledgeMode)

Method Detail

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                         String selector,
                                         boolean noLocal)
                                           throws javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException

Specified by:

createPublisher in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createProducer

public NevadoMessageProducer createProducer(javax.jms.Destination destination)
                                     throws javax.jms.JMSException

Specified by:

createProducer in interface javax.jms.Session

Overrides:

createProducer in class NevadoSession

Throws:

javax.jms.JMSException

createConsumer

public NevadoMessageConsumer createConsumer(javax.jms.Destination destination)
                                     throws javax.jms.JMSException

Specified by:

createConsumer in interface javax.jms.Session

Overrides:

createConsumer in class NevadoSession

Throws:

javax.jms.JMSException

createConsumer

public NevadoMessageConsumer createConsumer(javax.jms.Destination destination,
                                   String selector)
                                     throws javax.jms.JMSException

Specified by:

createConsumer in interface javax.jms.Session

Overrides:

createConsumer in class NevadoSession

Throws:

javax.jms.JMSException

createConsumer

public NevadoMessageConsumer createConsumer(javax.jms.Destination destination,
                                   String selector,
                                   boolean noLocal)
                                     throws javax.jms.JMSException

Specified by:

createConsumer in interface javax.jms.Session

Overrides:

createConsumer in class NevadoSession

Throws:

javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class NevadoSession

Throws:

javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                   String s)
                                     throws javax.jms.JMSException

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class NevadoSession

Throws:

javax.jms.JMSException

createTemporaryQueue

public NevadoTemporaryQueue createTemporaryQueue()
                                          throws javax.jms.JMSException

Specified by:

createTemporaryQueue in interface javax.jms.Session

Overrides:

createTemporaryQueue in class NevadoSession

Throws:

javax.jms.JMSException

createQueue

public NevadoQueue createQueue(String s)
                        throws javax.jms.JMSException

Specified by:

createQueue in interface javax.jms.Session

Overrides:

createQueue in class NevadoSession

Throws:

javax.jms.JMSException