public class OutboundConnection extends Object implements jakarta.jms.Connection, OutboundConnectionMBean
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).Modifier and Type | Field and Description |
---|---|
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) jakarta.jms.XAConnection |
xac
The physical connection this "handle" handles.
|
Constructor and Description |
---|
OutboundConnection(ManagedConnectionImpl managedCx,
jakarta.jms.XAConnection xac)
Constructs an
OutboundConnection instance. |
Modifier and Type | Method and 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. |
jakarta.jms.ConnectionConsumer |
createConnectionConsumer(jakarta.jms.Destination destination,
String messageSelector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages)
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
jakarta.jms.ConnectionConsumer |
createDurableConnectionConsumer(jakarta.jms.Topic topic,
String subscriptionName,
String messageSelector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages)
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
jakarta.jms.Session |
createSession() |
jakarta.jms.Session |
createSession(boolean transacted,
int acknowledgeMode)
Returns the unique authorized JMS session per connection wrapped
in an
OutboundSession instance. |
jakarta.jms.Session |
createSession(int sessionMode) |
jakarta.jms.ConnectionConsumer |
createSharedConnectionConsumer(jakarta.jms.Topic topic,
String subscriptionName,
String messageSelector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages) |
jakarta.jms.ConnectionConsumer |
createSharedDurableConnectionConsumer(jakarta.jms.Topic topic,
String subscriptionName,
String messageSelector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages) |
String |
getClientID()
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
jakarta.jms.ExceptionListener |
getExceptionListener()
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
String |
getJMXBeanName(jakarta.jms.XAConnection cnx) |
jakarta.jms.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(jakarta.jms.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() |
public static Logger logger
ManagedConnectionImpl managedCx
jakarta.jms.XAConnection xac
boolean valid
true
if this "handle" is valid.Vector<OutboundSession> sessions
OutboundConnection(ManagedConnectionImpl managedCx, jakarta.jms.XAConnection xac)
OutboundConnection
instance.managedCx
- The managed connection building the handle.xac
- The underlying physical connection to handle.public boolean cnxEquals(Object obj)
true
if the parameter is a Connection
instance sharing the same
proxy identifier and connection key.public void cleanup()
public jakarta.jms.Session createSession() throws jakarta.jms.JMSException
createSession
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.Session createSession(int sessionMode) throws jakarta.jms.JMSException
createSession
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.Session createSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
OutboundSession
instance.createSession
in interface jakarta.jms.Connection
jakarta.jms.IllegalStateException
- If the handle is invalid.jakarta.jms.JMSException
- Generic exception.public String getClientID() throws jakarta.jms.JMSException
IllegalStateException
instance.getClientID
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public void setClientID(String clientID) throws jakarta.jms.JMSException
IllegalStateException
instance.setClientID
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.ConnectionMetaData getMetaData() throws jakarta.jms.JMSException
getMetaData
in interface jakarta.jms.Connection
jakarta.jms.IllegalStateException
- If the handle is invalid.jakarta.jms.JMSException
- Generic exception.public jakarta.jms.ExceptionListener getExceptionListener() throws jakarta.jms.JMSException
IllegalStateException
instance.getExceptionListener
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public void setExceptionListener(jakarta.jms.ExceptionListener listener) throws jakarta.jms.JMSException
IllegalStateException
instance.setExceptionListener
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public void start() throws jakarta.jms.JMSException
start
in interface jakarta.jms.Connection
jakarta.jms.IllegalStateException
- If the handle is invalid.jakarta.jms.JMSException
- Generic exception.public void stop() throws jakarta.jms.JMSException
IllegalStateException
instance.stop
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.ConnectionConsumer createConnectionConsumer(jakarta.jms.Destination destination, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
IllegalStateException
instance.createConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.ConnectionConsumer createDurableConnectionConsumer(jakarta.jms.Topic topic, String subscriptionName, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
IllegalStateException
instance.createDurableConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public void close() throws jakarta.jms.JMSException
close
in interface jakarta.jms.Connection
close
in interface AutoCloseable
close
in interface OutboundConnectionMBean
jakarta.jms.IllegalStateException
- If the handle is invalid.jakarta.jms.JMSException
- Generic exception.public int getNumberOfSession()
getNumberOfSession
in interface OutboundConnectionMBean
public String[] getSessions()
getSessions
in interface OutboundConnectionMBean
public jakarta.jms.ConnectionConsumer createSharedConnectionConsumer(jakarta.jms.Topic topic, String subscriptionName, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
createSharedConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.ConnectionConsumer createSharedDurableConnectionConsumer(jakarta.jms.Topic topic, String subscriptionName, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
createSharedDurableConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public String getJMXBeanName(jakarta.jms.XAConnection cnx)
public String registerMBean()
public void unregisterMBean()
Copyright © 2023 ScalAgent D.T.. All rights reserved.