org.objectweb.joram.client.connector

Class OutboundTopicConnection

Implemented Interfaces:
javax.jms.Connection, javax.jms.TopicConnection

public class OutboundTopicConnection
extends OutboundConnection
implements javax.jms.TopicConnection

An OutboundTopicConnection instance is a handler for a physical PubSub connection to an underlying JORAM server, allowing a component to transparently use this physical connection possibly within a transaction (local or global).

Method Summary

ConnectionConsumer
createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages)
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
TopicSession
createTopicSession(boolean transacted, int acknowledgeMode)
Returns the unique authorized JMS session per connection wrapped in an OutboundTopicSession instance.

Methods inherited from class org.objectweb.joram.client.connector.OutboundConnection

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

Method Details

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Topic topic,
                                                   String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


createTopicSession

public TopicSession createTopicSession(boolean transacted,
                                       int acknowledgeMode)
            throws JMSException
Returns the unique authorized JMS session per connection wrapped in an OutboundTopicSession instance.


Copyright B) 2004 Scalagent - All rights reserved