org.apache.activemq.ra
public class ActiveMQManagedConnection extends java.lang.Object implements javax.resource.spi.ManagedConnection, javax.jms.ExceptionListener
Constructor and Description |
---|
ActiveMQManagedConnection(javax.security.auth.Subject subject,
ActiveMQConnection physicalConnection,
ActiveMQConnectionRequestInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
addConnectionEventListener(javax.resource.spi.ConnectionEventListener listener) |
void |
associate(javax.security.auth.Subject subject,
ActiveMQConnectionRequestInfo info) |
void |
associateConnection(java.lang.Object connection) |
void |
cleanup()
Cleans up all proxy handles attached to this physical connection so that
they cannot be used anymore.
|
void |
destroy()
Close down the physical connection to the server.
|
java.lang.Object |
getConnection(javax.security.auth.Subject subject,
javax.resource.spi.ConnectionRequestInfo info) |
javax.resource.spi.LocalTransaction |
getLocalTransaction() |
java.io.PrintWriter |
getLogWriter() |
javax.resource.spi.ManagedConnectionMetaData |
getMetaData() |
javax.jms.Connection |
getPhysicalConnection() |
TransactionContext |
getTransactionContext() |
javax.transaction.xa.XAResource |
getXAResource() |
boolean |
isInManagedTx() |
static boolean |
matches(java.lang.Object x,
java.lang.Object y) |
boolean |
matches(javax.security.auth.Subject subject,
javax.resource.spi.ConnectionRequestInfo info) |
void |
onException(javax.jms.JMSException e) |
void |
proxyClosedEvent(ManagedConnectionProxy proxy)
When a proxy is closed this cleans up the proxy and notifys the
ConnectionEventListeners that a connection closed.
|
void |
removeConnectionEventListener(javax.resource.spi.ConnectionEventListener listener) |
void |
setLogWriter(java.io.PrintWriter logWriter) |
public ActiveMQManagedConnection(javax.security.auth.Subject subject, ActiveMQConnection physicalConnection, ActiveMQConnectionRequestInfo info) throws javax.resource.ResourceException
javax.resource.ResourceException
public boolean isInManagedTx()
public static boolean matches(java.lang.Object x, java.lang.Object y)
public void associate(javax.security.auth.Subject subject, ActiveMQConnectionRequestInfo info) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Connection getPhysicalConnection()
public java.lang.Object getConnection(javax.security.auth.Subject subject, javax.resource.spi.ConnectionRequestInfo info) throws javax.resource.ResourceException
getConnection
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.getConnection(javax.security.auth.Subject,
javax.resource.spi.ConnectionRequestInfo)
public void destroy() throws javax.resource.ResourceException
destroy
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.destroy()
public void cleanup() throws javax.resource.ResourceException
cleanup
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.cleanup()
public void associateConnection(java.lang.Object connection) throws javax.resource.ResourceException
associateConnection
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.associateConnection(java.lang.Object)
public void addConnectionEventListener(javax.resource.spi.ConnectionEventListener listener)
addConnectionEventListener
in interface javax.resource.spi.ManagedConnection
ManagedConnection.addConnectionEventListener(javax.resource.spi.ConnectionEventListener)
public void removeConnectionEventListener(javax.resource.spi.ConnectionEventListener listener)
removeConnectionEventListener
in interface javax.resource.spi.ManagedConnection
ManagedConnection.removeConnectionEventListener(javax.resource.spi.ConnectionEventListener)
public javax.transaction.xa.XAResource getXAResource() throws javax.resource.ResourceException
getXAResource
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.getXAResource()
public javax.resource.spi.LocalTransaction getLocalTransaction() throws javax.resource.ResourceException
getLocalTransaction
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.getLocalTransaction()
public javax.resource.spi.ManagedConnectionMetaData getMetaData() throws javax.resource.ResourceException
getMetaData
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.getMetaData()
public void setLogWriter(java.io.PrintWriter logWriter) throws javax.resource.ResourceException
setLogWriter
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.setLogWriter(java.io.PrintWriter)
public java.io.PrintWriter getLogWriter() throws javax.resource.ResourceException
getLogWriter
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
ManagedConnection.getLogWriter()
public boolean matches(javax.security.auth.Subject subject, javax.resource.spi.ConnectionRequestInfo info)
subject
- subject to matchinfo
- cri to matchpublic void proxyClosedEvent(ManagedConnectionProxy proxy)
proxy
- public void onException(javax.jms.JMSException e)
onException
in interface javax.jms.ExceptionListener
public TransactionContext getTransactionContext()
Copyright © 2005-2014. All Rights Reserved.