org.fusesource.stompjms
Class StompJmsTopicSession

java.lang.Object
  org.fusesource.stompjms.StompJmsSession
      org.fusesource.stompjms.StompJmsTopicSession

All Implemented Interfaces:

java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession, StompJmsMessageListener

Direct Known Subclasses:

StompJmsQueueSession

public class StompJmsTopicSession
extends StompJmsSession

Implementation of a TopicSession

Field Summary

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

protected

StompJmsTopicSession(StompJmsConnection connection, StompChannel channel, int acknowledgementMode) Constructor

Method Summary

javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue)
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue, java.lang.String messageSelector)
javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination)
javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination, java.lang.String messageSelector)
javax.jms.MessageProducer	createProducer(javax.jms.Destination destination)
javax.jms.Queue	createQueue(java.lang.String queueName)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue, java.lang.String messageSelector)
javax.jms.QueueSender	createSender(javax.jms.Queue queue)
javax.jms.TemporaryQueue	createTemporaryQueue()

Methods inherited from class org.fusesource.stompjms.StompJmsSession

add, add, checkClosed, close, commit, createBytesMessage, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createPublisher, createStreamMessage, createSubscriber, createSubscriber, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getChannel, getConnection, getMessageListener, getTransacted, isStarted, onException, onException, onMessage, recover, remove, remove, rollback, run, send, setMessageListener, start, stop, unsubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

StompJmsTopicSession

protected StompJmsTopicSession(StompJmsConnection connection,
                               StompChannel channel,
                               int acknowledgementMode)

Constructor

Parameters:

connection -

acknowledgementMode -

Method Detail

createBrowser

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

Specified by:

createBrowser in interface javax.jms.QueueSession

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class StompJmsSession

Parameters:

queue -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createBrowser(javax.jms.Queue)

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String messageSelector)
                                     throws javax.jms.JMSException

Specified by:

createBrowser in interface javax.jms.QueueSession

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class StompJmsSession

Parameters:

queue -

messageSelector -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createBrowser(javax.jms.Queue, java.lang.String)

createConsumer

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

Specified by:

createConsumer in interface javax.jms.Session

Overrides:

createConsumer in class StompJmsSession

Parameters:

destination -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createConsumer(javax.jms.Destination)

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
                                                java.lang.String messageSelector)
                                         throws javax.jms.JMSException

Specified by:

createConsumer in interface javax.jms.Session

Overrides:

createConsumer in class StompJmsSession

Parameters:

destination -

messageSelector -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createConsumer(javax.jms.Destination, java.lang.String)

createProducer

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

Specified by:

createProducer in interface javax.jms.Session

Overrides:

createProducer in class StompJmsSession

Parameters:

destination -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createProducer(javax.jms.Destination)

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException

Specified by:

createQueue in interface javax.jms.QueueSession

Specified by:

createQueue in interface javax.jms.Session

Overrides:

createQueue in class StompJmsSession

Parameters:

queueName -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createQueue(java.lang.String)

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException

Specified by:

createTemporaryQueue in interface javax.jms.QueueSession

Specified by:

createTemporaryQueue in interface javax.jms.Session

Overrides:

createTemporaryQueue in class StompJmsSession

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createTemporaryQueue()

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException

Specified by:

createReceiver in interface javax.jms.QueueSession

Overrides:

createReceiver in class StompJmsSession

Parameters:

queue -

Returns:

Throws:

javax.jms.JMSException

See Also:

QueueSession.createReceiver(javax.jms.Queue)

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
                                              java.lang.String messageSelector)
                                       throws javax.jms.JMSException

Specified by:

createReceiver in interface javax.jms.QueueSession

Overrides:

createReceiver in class StompJmsSession

Parameters:

queue -

messageSelector -

Returns:

Throws:

javax.jms.JMSException

See Also:

QueueSession.createReceiver(javax.jms.Queue, java.lang.String)

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.JMSException

Specified by:

createSender in interface javax.jms.QueueSession

Overrides:

createSender in class StompJmsSession

Parameters:

queue -

Returns:

Throws:

javax.jms.JMSException

See Also:

QueueSession.createSender(javax.jms.Queue)