Package org.objectweb.joram.client.connector

Class OutboundConnection

java.lang.Object

org.objectweb.joram.client.connector.OutboundConnection

All Implemented Interfaces:

AutoCloseable, Connection, OutboundConnectionMBean

Direct Known Subclasses:

OutboundQueueConnection, OutboundTopicConnection

public class OutboundConnection
extends Object
implements Connection, OutboundConnectionMBean

An OutboundConnection instance is a handler for a physical 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
(package private) ManagedConnectionImpl	managedCx	The managed connection this "handle" belongs to.
(package private) Vector<OutboundSession>	sessions	Vector of the connection's sessions.
(package private) boolean	valid	true if this "handle" is valid.
(package private) XAConnection	xac	The physical connection this "handle" handles.

Constructor Summary

Constructors

Constructor	Description
OutboundConnection(ManagedConnectionImpl managedCx, XAConnection xac)	Constructs an OutboundConnection instance.

Method Summary

Modifier and Type	Method	Description
void	cleanup()	Close all sessions.
void	close()	Requests to close the physical connection.
boolean	cnxEquals(Object obj)	Returns true if the parameter is a Connection instance sharing the same proxy identifier and connection key.
ConnectionConsumer	createConnectionConsumer(Destination destination, String messageSelector, ServerSessionPool sessionPool, int maxMessages)	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
ConnectionConsumer	createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages)	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
(package private) Session	createManagedSession(int acknowledgeMode)
Session	createSession()
Session	createSession(boolean transacted, int acknowledgeMode)	Returns the unique authorized JMS session per connection wrapped in an OutboundSession instance.
Session	createSession(int sessionMode)
ConnectionConsumer	createSharedConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages)
ConnectionConsumer	createSharedDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages)
String	getClientID()	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
ExceptionListener	getExceptionListener()	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
String	getJMXBeanName(XAConnection cnx)
ConnectionMetaData	getMetaData()	Delegates the call to the wrapped JMS connection.
int	getNumberOfSession()
String[]	getSessions()
String	registerMBean()
void	setClientID(String clientID)	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
void	setExceptionListener(ExceptionListener listener)	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
void	start()	Delegates the call to the wrapped JMS connection.
void	stop()	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
String	toString()
void	unregisterMBean()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

managedCx

ManagedConnectionImpl managedCx

The managed connection this "handle" belongs to.

xac

XAConnection xac

The physical connection this "handle" handles.

valid

boolean valid

true if this "handle" is valid.

sessions

Vector<OutboundSession> sessions

Vector of the connection's sessions.

Constructor Detail

OutboundConnection

OutboundConnection(ManagedConnectionImpl managedCx,
                   XAConnection xac)

Constructs an OutboundConnection instance.

Parameters:

managedCx - The managed connection building the handle.

xac - The underlying physical connection to handle.

Method Detail

cnxEquals

public boolean cnxEquals(Object obj)

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

toString

public String toString()

Overrides:

toString in class Object

cleanup

public void cleanup()

Close all sessions.

createSession

public Session createSession()
                      throws JMSException

Specified by:

createSession in interface Connection

Throws:

JMSException

createSession

public Session createSession(int sessionMode)
                      throws JMSException

Specified by:

createSession in interface Connection

Throws:

JMSException

createSession

public Session createSession(boolean transacted,
                             int acknowledgeMode)
                      throws JMSException

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

Specified by:

createSession in interface Connection

Throws:

IllegalStateException - If the handle is invalid.

JMSException - Generic exception.

createManagedSession

Session createManagedSession(int acknowledgeMode)
                      throws JMSException

Throws:

JMSException

getClientID

public String getClientID()
                   throws JMSException

Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.

Specified by:

getClientID in interface Connection

Throws:

JMSException

setClientID

public void setClientID(String clientID)
                 throws JMSException

Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.

Specified by:

setClientID in interface Connection

Throws:

JMSException

getMetaData

public ConnectionMetaData getMetaData()
                               throws JMSException

Delegates the call to the wrapped JMS connection.

Specified by:

getMetaData in interface Connection

Throws:

IllegalStateException - If the handle is invalid.

JMSException - Generic exception.

getExceptionListener

public ExceptionListener getExceptionListener()
                                       throws JMSException

Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.

Specified by:

getExceptionListener in interface Connection

Throws:

JMSException

setExceptionListener

public void setExceptionListener(ExceptionListener listener)
                          throws JMSException

Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.

Specified by:

setExceptionListener in interface Connection

Throws:

JMSException

start

public void start()
           throws JMSException

Delegates the call to the wrapped JMS connection.

Specified by:

start in interface Connection

Throws:

IllegalStateException - If the handle is invalid.

JMSException - Generic exception.

stop

public void stop()
          throws JMSException

Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.

Specified by:

stop in interface Connection

Throws:

JMSException

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Destination destination,
                                                   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 Connection

Throws:

JMSException

createDurableConnectionConsumer

public ConnectionConsumer createDurableConnectionConsumer(Topic topic,
                                                          String subscriptionName,
                                                          String messageSelector,
                                                          ServerSessionPool sessionPool,
                                                          int maxMessages)
                                                   throws JMSException

Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.

Specified by:

createDurableConnectionConsumer in interface Connection

Throws:

JMSException

close

public void close()
           throws JMSException

Requests to close the physical connection.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Connection

Specified by:

close in interface OutboundConnectionMBean

Throws:

IllegalStateException - If the handle is invalid.

JMSException - Generic exception.

getNumberOfSession

public int getNumberOfSession()

Specified by:

getNumberOfSession in interface OutboundConnectionMBean

getSessions

public String[] getSessions()

Specified by:

getSessions in interface OutboundConnectionMBean

createSharedConnectionConsumer

public ConnectionConsumer createSharedConnectionConsumer(Topic topic,
                                                         String subscriptionName,
                                                         String messageSelector,
                                                         ServerSessionPool sessionPool,
                                                         int maxMessages)
                                                  throws JMSException

Specified by:

createSharedConnectionConsumer in interface Connection

Throws:

JMSException

createSharedDurableConnectionConsumer

public ConnectionConsumer createSharedDurableConnectionConsumer(Topic topic,
                                                                String subscriptionName,
                                                                String messageSelector,
                                                                ServerSessionPool sessionPool,
                                                                int maxMessages)
                                                         throws JMSException

Specified by:

createSharedDurableConnectionConsumer in interface Connection

Throws:

JMSException

getJMXBeanName

public String getJMXBeanName(XAConnection cnx)

registerMBean

public String registerMBean()

unregisterMBean

public void unregisterMBean()