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

Constructors

Constructor and Description
StompJmsQueueConnection(java.net.URI brokerURI, java.net.URI localURI, java.lang.String userName, java.lang.String password, javax.net.ssl.SSLContext sslContext)

Method Summary

Methods

Modifier and Type	Method and Description
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, getDisconnectTimeout, getExceptionListener, getMetaData, getPrefetch, getQueuePrefix, getSessionAcknowledgeMode, getTempQueuePrefix, getTempTopicPrefix, getTopicPrefix, isForceAsyncSend, isOmitHost, onException, onException, removeSession, setClientID, setDisconnectTimeout, 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,
                       javax.net.ssl.SSLContext sslContext)
                        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)