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

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

Method Summary

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)