public class OutboundQueueConnection extends OutboundConnection implements jakarta.jms.QueueConnection
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).Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
managedCx, sessions, valid, xac
Constructor and Description |
---|
OutboundQueueConnection(ManagedConnectionImpl managedCx,
jakarta.jms.XAQueueConnection xac)
Constructs an
OutboundQueueConnection instance. |
Modifier and Type | Method and 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. |
cleanup, close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getJMXBeanName, getMetaData, getNumberOfSession, getSessions, registerMBean, setClientID, setExceptionListener, start, stop, toString, unregisterMBean
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
public static Logger logger
OutboundQueueConnection(ManagedConnectionImpl managedCx, jakarta.jms.XAQueueConnection xac)
OutboundQueueConnection
instance.managedCx
- The managed connection building the handle.xac
- The underlying physical PTP connection to handle.public boolean cnxEquals(Object obj)
OutboundConnection
true
if the parameter is a Connection
instance sharing the same
proxy identifier and connection key.cnxEquals
in class OutboundConnection
public jakarta.jms.QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
OutboundQueueSession
instance.createQueueSession
in interface jakarta.jms.QueueConnection
jakarta.jms.IllegalStateException
- If the handle is invalid.jakarta.jms.JMSException
- Generic exception.public jakarta.jms.ConnectionConsumer createConnectionConsumer(jakarta.jms.Queue queue, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
IllegalStateException
instance.createConnectionConsumer
in interface jakarta.jms.QueueConnection
jakarta.jms.JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.