org.fusesource.stomp.jms
Class StompJmsQueueConnection

java.lang.Object
  org.fusesource.stomp.jms.StompJmsConnection
      org.fusesource.stomp.jms.StompJmsQueueConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.QueueConnection, javax.jms.TopicConnection

public class StompJmsQueueConnection
extends StompJmsConnection

Author:

Hiram Chirino

Constructor Summary

StompJmsQueueConnection(java.net.URI brokerURI, java.net.URI localURI, java.lang.String userName, java.lang.String password)

Method Summary

javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
javax.jms.ConnectionConsumer	createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
javax.jms.TopicSession	createTopicSession(boolean transacted, int acknowledgeMode)

Methods inherited from class org.fusesource.stomp.jms.StompJmsConnection

addSession, checkClosed, close, createChannel, createChannel, createConnectionConsumer, createConnectionConsumer, createQueueSession, createSession, getChannel, getClientID, getExceptionListener, getMetaData, getPrefetch, getQueuePrefix, getSessionAcknowledgeMode, getTempQueuePrefix, getTempTopicPrefix, getTopicPrefix, isForceAsyncSend, isOmitHost, onException, onException, removeSession, setClientID, setExceptionListener, setForceAsyncSend, setOmitHost, setPrefetch, setQueuePrefix, setTempQueuePrefix, setTempTopicPrefix, setTopicPrefix, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

StompJmsQueueConnection

public StompJmsQueueConnection(java.net.URI brokerURI,
                               java.net.URI localURI,
                               java.lang.String userName,
                               java.lang.String password)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

createTopicSession

public javax.jms.TopicSession createTopicSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException

Specified by:

createTopicSession in interface javax.jms.TopicConnection

Overrides:

createTopicSession in class StompJmsConnection

Returns:

TopicSession

Throws:

javax.jms.JMSException

See Also:

TopicConnection.createTopicSession(boolean, int)

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String subscriptionName,
                                                                    java.lang.String messageSelector,
                                                                    javax.jms.ServerSessionPool sessionPool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException

Specified by:

createDurableConnectionConsumer in interface javax.jms.Connection

Specified by:

createDurableConnectionConsumer in interface javax.jms.TopicConnection

Overrides:

createDurableConnectionConsumer in class StompJmsConnection

Returns:

ConnectionConsumer

Throws:

javax.jms.JMSException

See Also:

Connection.createDurableConnectionConsumer(javax.jms.Topic, java.lang.String, java.lang.String, javax.jms.ServerSessionPool, int)

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException

Specified by:

createConnectionConsumer in interface javax.jms.TopicConnection

Overrides:

createConnectionConsumer in class StompJmsConnection

Returns:

ConnectionConsumer

Throws:

javax.jms.JMSException

See Also:

TopicConnection.createConnectionConsumer(javax.jms.Topic, java.lang.String, javax.jms.ServerSessionPool, int)