org.objectweb.joram.client.jms
Class TopicConnection

java.lang.Object
  org.objectweb.joram.client.jms.Connection
      org.objectweb.joram.client.jms.TopicConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.TopicConnection

Direct Known Subclasses:

XATopicConnection

public class TopicConnection

extends Connection

implements javax.jms.TopicConnection

Implements the javax.jms.TopicConnection interface.

Constructor Summary

TopicConnection(FactoryParameters factoryParameters, RequestChannel requestChannel)
Creates a TopicConnection instance.

Method Summary

javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Topic topic, java.lang.String selector, javax.jms.ServerSessionPool sessionPool, int maxMessages) API method.
javax.jms.ConnectionConsumer	createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subName, java.lang.String selector, javax.jms.ServerSessionPool sessPool, int maxMessages) API method.
javax.jms.TopicSession	createTopicSession(boolean transacted, int acknowledgeMode) API method.

Methods inherited from class org.objectweb.joram.client.jms.Connection

addSession, checkClosed, cleanup, close, createConnectionConsumer, createSession, equals, getClientID, getExceptionListener, getMetaData, getRequestMultiplexer, setClientID, setExceptionListener, start, stop, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Constructor Detail

TopicConnection

public TopicConnection(FactoryParameters factoryParameters,
                       RequestChannel requestChannel)
                throws javax.jms.JMSException

Creates a TopicConnection instance.

Parameters:

factoryParameters - The factory parameters.

Throws:

JMSSecurityException - If the user identification is incorrect.

javax.jms.IllegalStateException - If the server is not listening.

javax.jms.JMSException

Method Detail

createConnectionConsumer

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

API method.

Specified by:

createConnectionConsumer in interface javax.jms.TopicConnection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

InvalidSelectorException - If the selector syntax is wrong.

InvalidDestinationException - If the target destination does not exist.

javax.jms.JMSException - If the method fails for any other reason.

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String subName,
                                                                    java.lang.String selector,
                                                                    javax.jms.ServerSessionPool sessPool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException

API method.

Specified by:

createDurableConnectionConsumer in interface javax.jms.TopicConnection

Overrides:

createDurableConnectionConsumer in class Connection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

InvalidSelectorException - If the selector syntax is wrong.

InvalidDestinationException - If the target topic does not exist.

javax.jms.JMSException - If the method fails for any other reason.

createTopicSession

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

API method.

Specified by:

createTopicSession in interface javax.jms.TopicConnection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

javax.jms.JMSException - In case of an invalid acknowledge mode.