Package org.ow2.joram.jakarta.connector

Class OutboundQueueConnection

java.lang.Object

org.ow2.joram.jakarta.connector.OutboundConnection

org.ow2.joram.jakarta.connector.OutboundQueueConnection

All Implemented Interfaces:

jakarta.jms.Connection, jakarta.jms.QueueConnection, AutoCloseable, OutboundConnectionMBean

public class OutboundQueueConnection
extends OutboundConnection
implements jakarta.jms.QueueConnection

An OutboundQueueConnection instance is a handler for a physical PTP 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.ow2.joram.jakarta.connector.OutboundConnection

managedCx, sessions, valid, xac

Constructor Summary

Constructors

Constructor	Description
OutboundQueueConnection(ManagedConnectionImpl managedCx, jakarta.jms.XAQueueConnection xac)	Constructs an OutboundQueueConnection 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.
jakarta.jms.ConnectionConsumer	createConnectionConsumer(jakarta.jms.Queue queue, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages)	Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
jakarta.jms.QueueSession	createQueueSession(boolean transacted, int acknowledgeMode)	Returns the unique authorized JMS session per connection wrapped in an OutboundQueueSession instance.

Methods inherited from class org.ow2.joram.jakarta.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 jakarta.jms.Connection

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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

Constructor Detail

OutboundQueueConnection

OutboundQueueConnection(ManagedConnectionImpl managedCx,
                        jakarta.jms.XAQueueConnection xac)

Constructs an OutboundQueueConnection instance.

Parameters:

managedCx - The managed connection building the handle.

xac - The underlying physical PTP 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

createQueueSession

public jakarta.jms.QueueSession createQueueSession(boolean transacted,
                                                   int acknowledgeMode)
                                            throws jakarta.jms.JMSException

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

Specified by:

createQueueSession in interface jakarta.jms.QueueConnection

Throws:

jakarta.jms.IllegalStateException - If the handle is invalid.

jakarta.jms.JMSException - Generic exception.

createConnectionConsumer

public jakarta.jms.ConnectionConsumer createConnectionConsumer(jakarta.jms.Queue queue,
                                                               String messageSelector,
                                                               jakarta.jms.ServerSessionPool sessionPool,
                                                               int maxMessages)
                                                        throws jakarta.jms.JMSException

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

Specified by:

createConnectionConsumer in interface jakarta.jms.QueueConnection

Throws:

jakarta.jms.JMSException