ActiveMQManagedConnection

Overview

Package

Class

Use

Deprecated

Index

Home >> All >> org >> activemq >> [ ra overview ]

PREV CLASS NEXT CLASS

SUMMARY:

JAVADOC |

Sourc code of org.activemq.ra.ActiveMQManagedConnection

SOURCE |

Download org.activemq.ra.ActiveMQManagedConnection

DOWNLOAD | NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.activemq.ra
Class ActiveMQManagedConnection

java.lang.Object
  org.activemq.ra.ActiveMQManagedConnection

All Implemented Interfaces:: javax.jms.ExceptionListener, javax.resource.spi.ManagedConnection

public class ActiveMQManagedConnection
extends java.lang.Object
implements javax.resource.spi.ManagedConnection, javax.jms.ExceptionListener

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.

Version:: $Revision: 1.1.1.1 $

Field Summary

private boolean destoryed


private ActiveMQConnectionRequestInfo info


private java.util.ArrayList listeners


private LocalAndXATransaction localAndXATransaction


private static org.apache.commons.logging.Log log


private java.io.PrintWriter logWriter


private org.activemq.ActiveMQConnection physicalConnection


private java.util.ArrayList proxyConnections


private javax.security.auth.Subject subject


private org.activemq.TransactionContext transactionContext


Constructor Summary

ActiveMQManagedConnection(javax.security.auth.Subject subject, org.activemq.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.

private void fireBeginEvent()


private void fireCloseEvent(JMSConnectionProxy proxy)


private void fireCommitEvent()


private void fireErrorOccurredEvent(java.lang.Exception error)


private void fireRollbackEvent()


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()


org.activemq.TransactionContext getTransactionContext()


javax.transaction.xa.XAResource getXAResource()


private boolean isDestroyed()


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(JMSConnectionProxy 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

Field Detail

log

private static final org.apache.commons.logging.Log log

logWriter

private java.io.PrintWriter logWriter

physicalConnection

private final org.activemq.ActiveMQConnection physicalConnection

transactionContext

private final org.activemq.TransactionContext transactionContext

proxyConnections

private final java.util.ArrayList proxyConnections

listeners

private final java.util.ArrayList listeners

localAndXATransaction

private final LocalAndXATransaction localAndXATransaction

subject

private javax.security.auth.Subject subject

info

private ActiveMQConnectionRequestInfo info

destoryed

private boolean destoryed

Constructor Detail