|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.ra.ActiveMQManagedConnection
public class ActiveMQManagedConnection
ActiveMQManagedConnection maps to real physical connection to the server. Since a ManagedConnection has to provide a transaction managment interface to the physical connection, and sessions are the objects implement transaction managment interfaces in the JMS API, this object also maps to a singe physical JMS session.
The side-effect is that JMS connection the application gets will allways create the same session object. This is good if running in an app server since the sessions are elisted in the context transaction. This is bad if used outside of an app server since the user may be trying to create 2 different sessions to coordinate 2 different uow.
Constructor Summary | |
---|---|
ActiveMQManagedConnection(javax.security.auth.Subject subject,
ActiveMQConnection physicalConnection,
ActiveMQConnectionRequestInfo info)
|
Method Summary | |
---|---|
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)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ActiveMQManagedConnection(javax.security.auth.Subject subject, ActiveMQConnection physicalConnection, ActiveMQConnectionRequestInfo info) throws javax.resource.ResourceException
javax.resource.ResourceException
Method Detail |
---|
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 match
public void proxyClosedEvent(ManagedConnectionProxy proxy)
proxy
- public void onException(javax.jms.JMSException e)
onException
in interface javax.jms.ExceptionListener
public TransactionContext getTransactionContext()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |