org.apache.activemq.broker
public class TransportConnectionState extends ConnectionState
Constructor and Description |
---|
TransportConnectionState(ConnectionInfo info,
TransportConnection transportConnection) |
Modifier and Type | Method and Description |
---|---|
int |
decrementReference() |
TransportConnection |
getConnection() |
java.lang.Object |
getConnectionMutex() |
ConnectionContext |
getContext() |
java.util.concurrent.atomic.AtomicInteger |
getReferenceCounter() |
int |
incrementReference() |
void |
setConnection(TransportConnection connection) |
void |
setContext(ConnectionContext context) |
void |
setReferenceCounter(java.util.concurrent.atomic.AtomicInteger referenceCounter) |
addSession, addTempDestination, addTransactionState, getInfo, getRecoveringPullConsumers, getSessionIds, getSessionState, getSessionStates, getTempDestinations, getTransactionState, getTransactionStates, isConnectionInterruptProcessingComplete, removeSession, removeTempDestination, removeTransactionState, reset, setConnectionInterruptProcessingComplete, shutdown, toString
public TransportConnectionState(ConnectionInfo info, TransportConnection transportConnection)
public ConnectionContext getContext()
public TransportConnection getConnection()
public void setContext(ConnectionContext context)
public void setConnection(TransportConnection connection)
public int incrementReference()
public int decrementReference()
public java.util.concurrent.atomic.AtomicInteger getReferenceCounter()
public void setReferenceCounter(java.util.concurrent.atomic.AtomicInteger referenceCounter)
public java.lang.Object getConnectionMutex()
Copyright © 2005-2014. All Rights Reserved.