public class ConnectionState extends Object
Constructor and Description |
---|
ConnectionState(ConnectionInfo info) |
Modifier and Type | Method and 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() |
public ConnectionState(ConnectionInfo info)
public void reset(ConnectionInfo info)
public void addTempDestination(DestinationInfo info)
public void removeTempDestination(ActiveMQDestination destination)
public void addTransactionState(TransactionId id)
public TransactionState getTransactionState(TransactionId id)
public Collection<TransactionState> getTransactionStates()
public TransactionState removeTransactionState(TransactionId id)
public void addSession(SessionInfo info)
public SessionState removeSession(SessionId id)
public SessionState getSessionState(SessionId id)
public ConnectionInfo getInfo()
public Set<SessionId> getSessionIds()
public List<DestinationInfo> getTempDestinations()
public Collection<SessionState> getSessionStates()
public void shutdown()
public Map<ConsumerId,ConsumerInfo> getRecoveringPullConsumers()
public void setConnectionInterruptProcessingComplete(boolean connectionInterruptProcessingComplete)
public boolean isConnectionInterruptProcessingComplete()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.