org.apache.activemq.state
Class ConnectionState
java.lang.Object
org.apache.activemq.state.ConnectionState
- Direct Known Subclasses:
- TransportConnectionState
public class ConnectionState
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
ConnectionState
public ConnectionState(ConnectionInfo info)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
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 java.util.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()
getSessionIds
public java.util.Set<SessionId> getSessionIds()
getTempDestinations
public java.util.List<DestinationInfo> getTempDestinations()
getSessionStates
public java.util.Collection<SessionState> getSessionStates()
shutdown
public void shutdown()
getRecoveringPullConsumers
public java.util.Map<ConsumerId,ConsumerInfo> getRecoveringPullConsumers()
setConnectionInterruptProcessingComplete
public void setConnectionInterruptProcessingComplete(boolean connectionInterruptProcessingComplete)
isConnectionInterruptProcessingComplete
public boolean isConnectionInterruptProcessingComplete()
Copyright © 2005-2016. All Rights Reserved.