org.objectweb.joram.client.jms

Class TopicConnection

Implemented Interfaces:
javax.jms.Connection, javax.jms.TopicConnection
Known Direct Subclasses:
XATopicConnection

public class TopicConnection
extends Connection
implements javax.jms.TopicConnection

Implements the javax.jms.TopicConnection interface.

Field Summary

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

repliesTable, requestsTable, sessions

Constructor Summary

TopicConnection(FactoryParameters factoryParameters, ConnectionItf connectionImpl)
Creates a TopicConnection instance.

Method Summary

javax.jms.ConnectionConsumer
createConnectionConsumer(javax.jms.Topic topic, String selector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
API method.
javax.jms.ConnectionConsumer
createDurableConnectionConsumer(javax.jms.Topic topic, String subName, 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

close, createConnectionConsumer, createDurableConnectionConsumer, createSession, equals, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop, toString

Constructor Details

TopicConnection

public TopicConnection(FactoryParameters factoryParameters,
                       ConnectionItf connectionImpl)
            throws JMSException
Creates a TopicConnection instance.

Parameters:
factoryParameters - The factory parameters.
connectionImpl - The actual connection to wrap.

Method Details

createConnectionConsumer

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


createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    String subName,
                                                                    String selector,
                                                                    javax.jms.ServerSessionPool sessPool,
                                                                    int maxMessages)
            throws JMSException
API method.
Overrides:
createDurableConnectionConsumer in interface Connection


createTopicSession

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


Copyright B) 2004 Scalagent - All rights reserved