org.fusesource.stomp.jms

Class StompJmsTopicConnection

java.lang.Object

org.fusesource.stomp.jms.StompJmsConnection

org.fusesource.stomp.jms.StompJmsTopicConnection

All Implemented Interfaces:

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

public class StompJmsTopicConnection
extends StompJmsConnection

Author:

Hiram Chirino

Constructor Summary

Constructors

Constructor and Description
StompJmsTopicConnection(java.net.URI brokerURI, java.net.URI localURI, java.lang.String userName, java.lang.String password)

Method Summary

Methods

Modifier and Type	Method and Description
javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Queue queue, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
javax.jms.QueueSession	createQueueSession(boolean transacted, int acknowledgeMode)

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

addSession, checkClosed, close, createChannel, createChannel, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createSession, createTopicSession, 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

StompJmsTopicConnection

public StompJmsTopicConnection(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

createConnectionConsumer

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

Specified by:

createConnectionConsumer in interface javax.jms.QueueConnection

Overrides:

createConnectionConsumer in class StompJmsConnection

Returns:

ConnectionConsumer

Throws:

javax.jms.JMSException

See Also:

QueueConnection.createConnectionConsumer(javax.jms.Queue, java.lang.String, javax.jms.ServerSessionPool, int)

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                        int acknowledgeMode)
                                          throws javax.jms.JMSException

Specified by:

createQueueSession in interface javax.jms.QueueConnection

Overrides:

createQueueSession in class StompJmsConnection

Returns:

QueueSession

Throws:

javax.jms.JMSException

See Also:

QueueConnection.createQueueSession(boolean, int)