Joram ${version}

org.objectweb.joram.client.jms
Class TopicConnection

java.lang.Object
  extended byorg.objectweb.joram.client.jms.Connection
      extended byorg.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.

Joram ${version}

Copyright © 2005 Scalagent - All rights reserved