org.fusesource.stompjms
Class StompJmsQueueSession

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

All Implemented Interfaces:

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

public class StompJmsQueueSession
extends StompJmsTopicSession

Jms QueueSession implementation

Field Summary

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

protected

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

Method Summary

javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination)
javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination, java.lang.String messageSelector)
javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination, java.lang.String messageSelector, boolean NoLocal)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
javax.jms.MessageProducer	createProducer(javax.jms.Destination destination)
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal)
javax.jms.TemporaryTopic	createTemporaryTopic()
javax.jms.Topic	createTopic(java.lang.String topicName)
void	unsubscribe(java.lang.String name)

Methods inherited from class org.fusesource.stompjms.StompJmsTopicSession

createBrowser, createBrowser, createQueue, createReceiver, createReceiver, createSender, createTemporaryQueue

Methods inherited from class org.fusesource.stompjms.StompJmsSession

add, add, checkClosed, close, commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getChannel, getConnection, getMessageListener, getTransacted, isStarted, onException, onException, onMessage, recover, remove, remove, rollback, run, send, setMessageListener, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

StompJmsQueueSession

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

Constructor

Parameters:

connection -

acknowledgementMode -

Method Detail

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 StompJmsTopicSession

Returns:

a MessageConsumer

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 StompJmsTopicSession

Parameters:

destination -

messageSelector -

Returns:

Throws:

javax.jms.JMSException

See Also:

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

createConsumer

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

Specified by:

createConsumer in interface javax.jms.Session

Overrides:

createConsumer in class StompJmsSession

Parameters:

destination -

messageSelector -

NoLocal -

Returns:

Throws:

javax.jms.JMSException

See Also:

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

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name)
                                                  throws javax.jms.JMSException

Specified by:

createDurableSubscriber in interface javax.jms.Session

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Overrides:

createDurableSubscriber in class StompJmsSession

Parameters:

topic -

name -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createDurableSubscriber(javax.jms.Topic, java.lang.String)

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name,
                                                         java.lang.String messageSelector,
                                                         boolean noLocal)
                                                  throws javax.jms.IllegalStateException

Specified by:

createDurableSubscriber in interface javax.jms.Session

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Overrides:

createDurableSubscriber in class StompJmsSession

Parameters:

topic -

name -

messageSelector -

noLocal -

Returns:

Throws:

javax.jms.IllegalStateException

javax.jms.JMSException

See Also:

Session.createDurableSubscriber(javax.jms.Topic, java.lang.String, java.lang.String, boolean)

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 StompJmsTopicSession

Parameters:

destination -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createProducer(javax.jms.Destination)

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException

Specified by:

createTemporaryTopic in interface javax.jms.Session

Specified by:

createTemporaryTopic in interface javax.jms.TopicSession

Overrides:

createTemporaryTopic in class StompJmsSession

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createTemporaryTopic()

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.JMSException

Specified by:

createTopic in interface javax.jms.Session

Specified by:

createTopic in interface javax.jms.TopicSession

Overrides:

createTopic in class StompJmsSession

Parameters:

topicName -

Returns:

Throws:

javax.jms.JMSException

See Also:

Session.createTopic(java.lang.String)

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException

Specified by:

unsubscribe in interface javax.jms.Session

Specified by:

unsubscribe in interface javax.jms.TopicSession

Overrides:

unsubscribe in class StompJmsSession

Parameters:

name -

Throws:

javax.jms.JMSException

See Also:

Session.unsubscribe(java.lang.String)

createPublisher

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

Specified by:

createPublisher in interface javax.jms.TopicSession

Overrides:

createPublisher in class StompJmsSession

Parameters:

topic -

Returns:

Throws:

javax.jms.JMSException

See Also:

TopicSession.createPublisher(javax.jms.Topic)

createSubscriber

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

Specified by:

createSubscriber in interface javax.jms.TopicSession

Overrides:

createSubscriber in class StompJmsSession

Parameters:

topic -

Returns:

Throws:

javax.jms.JMSException

See Also:

TopicSession.createSubscriber(javax.jms.Topic)

createSubscriber

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

Specified by:

createSubscriber in interface javax.jms.TopicSession

Overrides:

createSubscriber in class StompJmsSession

Parameters:

topic -

messageSelector -

noLocal -

Returns:

Throws:

javax.jms.JMSException

See Also:

TopicSession.createSubscriber(javax.jms.Topic, java.lang.String, boolean)