Package org.objectweb.joram.client.connector

Class OutboundTopicConnection

java.lang.Object

org.objectweb.joram.client.connector.OutboundConnection

org.objectweb.joram.client.connector.OutboundTopicConnection

All Implemented Interfaces:

AutoCloseable, Connection, TopicConnection, OutboundConnectionMBean

public class OutboundTopicConnection
extends OutboundConnection
implements 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).

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger

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

managedCx, sessions, valid, xac

Constructor Summary

Constructors

Constructor	Description
OutboundTopicConnection(ManagedConnectionImpl managedCx, XATopicConnection xac)	Constructs an OutboundTopicConnection instance.

Method Summary

Modifier and Type	Method	Description
boolean	cnxEquals(Object obj)	Returns true if the parameter is a Connection instance sharing the same proxy identifier and connection key.
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, createConnectionConsumer, createDurableConnectionConsumer, createManagedSession, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getJMXBeanName, getMetaData, getNumberOfSession, getSessions, registerMBean, setClientID, setExceptionListener, start, stop, toString, unregisterMBean

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.Connection

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

Methods inherited from interface javax.jms.TopicConnection

createDurableConnectionConsumer

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

Constructor Detail

OutboundTopicConnection

OutboundTopicConnection(ManagedConnectionImpl managedCx,
                        XATopicConnection xac)

Constructs an OutboundTopicConnection instance.

Parameters:

managedCx - The managed connection building the handle.

xac - The underlying physical PubSub connection to handle.

Method Detail

cnxEquals

public boolean cnxEquals(Object obj)

Description copied from class: OutboundConnection

Returns true if the parameter is a Connection instance sharing the same proxy identifier and connection key.

Overrides:

cnxEquals in class OutboundConnection

createTopicSession

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

Returns the unique authorized JMS session per connection wrapped in an OutboundTopicSession instance.

Specified by:

createTopicSession in interface TopicConnection

Throws:

IllegalStateException - If the handle is invalid.

JMSException - Generic exception.

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.

Specified by:

createConnectionConsumer in interface TopicConnection

Throws:

JMSException