Package org.apache.activemq.state
Class ConnectionState
- java.lang.Object
-
- org.apache.activemq.state.ConnectionState
-
- Direct Known Subclasses:
TransportConnectionState
public class ConnectionState extends Object
-
-
Constructor Summary
Constructors Constructor Description ConnectionState(ConnectionInfo info)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addSession(SessionInfo info)
void
addTempDestination(DestinationInfo info)
void
addTransactionState(TransactionId id)
ConnectionInfo
getInfo()
Map<ConsumerId,ConsumerInfo>
getRecoveringPullConsumers()
Set<SessionId>
getSessionIds()
SessionState
getSessionState(SessionId id)
Collection<SessionState>
getSessionStates()
List<DestinationInfo>
getTempDestinations()
TransactionState
getTransactionState(TransactionId id)
Collection<TransactionState>
getTransactionStates()
boolean
isConnectionInterruptProcessingComplete()
SessionState
removeSession(SessionId id)
void
removeTempDestination(ActiveMQDestination destination)
TransactionState
removeTransactionState(TransactionId id)
void
reset(ConnectionInfo info)
void
setConnectionInterruptProcessingComplete(boolean connectionInterruptProcessingComplete)
void
shutdown()
String
toString()
-
-
-
Constructor Detail
-
ConnectionState
public ConnectionState(ConnectionInfo info)
-
-
Method Detail
-
reset
public void reset(ConnectionInfo info)
-
addTempDestination
public void addTempDestination(DestinationInfo info)
-
removeTempDestination
public void removeTempDestination(ActiveMQDestination destination)
-
addTransactionState
public void addTransactionState(TransactionId id)
-
getTransactionState
public TransactionState getTransactionState(TransactionId id)
-
getTransactionStates
public Collection<TransactionState> getTransactionStates()
-
removeTransactionState
public TransactionState removeTransactionState(TransactionId id)
-
addSession
public void addSession(SessionInfo info)
-
removeSession
public SessionState removeSession(SessionId id)
-
getSessionState
public SessionState getSessionState(SessionId id)
-
getInfo
public ConnectionInfo getInfo()
-
getTempDestinations
public List<DestinationInfo> getTempDestinations()
-
getSessionStates
public Collection<SessionState> getSessionStates()
-
shutdown
public void shutdown()
-
getRecoveringPullConsumers
public Map<ConsumerId,ConsumerInfo> getRecoveringPullConsumers()
-
setConnectionInterruptProcessingComplete
public void setConnectionInterruptProcessingComplete(boolean connectionInterruptProcessingComplete)
-
isConnectionInterruptProcessingComplete
public boolean isConnectionInterruptProcessingComplete()
-
-