Home » activemq-parent-5.3.1-source-release » org.apache » activemq » state » [javadoc | source]
org.apache.activemq.state
public class: ConnectionStateTracker [javadoc | source]
java.lang.Object
   org.apache.activemq.state.CommandVisitorAdapter
      org.apache.activemq.state.ConnectionStateTracker

All Implemented Interfaces:
    CommandVisitor

Tracks the state of a connection so a newly established transport can be re-initialized to the state that was tracked.
Field Summary
protected final  ConcurrentHashMap<ConnectionId, ConnectionState> connectionStates     
Method from org.apache.activemq.state.ConnectionStateTracker Summary:
getMaxCacheSize,   isRestoreConsumers,   isRestoreProducers,   isRestoreSessions,   isRestoreTransaction,   isTrackMessages,   isTrackTransactionProducers,   isTrackTransactions,   processAddConnection,   processAddConsumer,   processAddDestination,   processAddProducer,   processAddSession,   processBeginTransaction,   processCommitTransactionOnePhase,   processCommitTransactionTwoPhase,   processEndTransaction,   processMessage,   processPrepareTransaction,   processRemoveConnection,   processRemoveConsumer,   processRemoveDestination,   processRemoveProducer,   processRemoveSession,   processRollbackTransaction,   restore,   restoreConsumers,   restoreProducers,   restoreSessions,   restoreTempDestinations,   setMaxCacheSize,   setRestoreConsumers,   setRestoreProducers,   setRestoreSessions,   setRestoreTransaction,   setTrackMessages,   setTrackTransactionProducers,   setTrackTransactions,   track,   trackBack
Methods from org.apache.activemq.state.CommandVisitorAdapter:
processAddConnection,   processAddConsumer,   processAddDestination,   processAddProducer,   processAddSession,   processBeginTransaction,   processBrokerInfo,   processCommitTransactionOnePhase,   processCommitTransactionTwoPhase,   processConnectionControl,   processConnectionError,   processConsumerControl,   processControlCommand,   processEndTransaction,   processFlush,   processForgetTransaction,   processKeepAlive,   processMessage,   processMessageAck,   processMessageDispatch,   processMessageDispatchNotification,   processMessagePull,   processPrepareTransaction,   processProducerAck,   processRecoverTransactions,   processRemoveConnection,   processRemoveConsumer,   processRemoveDestination,   processRemoveProducer,   processRemoveSession,   processRemoveSubscription,   processRollbackTransaction,   processShutdown,   processWireFormat
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.state.ConnectionStateTracker Detail:
 public int getMaxCacheSize() 
 public boolean isRestoreConsumers() 
 public boolean isRestoreProducers() 
 public boolean isRestoreSessions() 
 public boolean isRestoreTransaction() 
 public boolean isTrackMessages() 
 public boolean isTrackTransactionProducers() 
 public boolean isTrackTransactions() 
 public Response processAddConnection(ConnectionInfo info) 
 public Response processAddConsumer(ConsumerInfo info) 
 public Response processAddDestination(DestinationInfo info) 
 public Response processAddProducer(ProducerInfo info) 
 public Response processAddSession(SessionInfo info) 
 public Response processBeginTransaction(TransactionInfo info) 
 public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception 
 public Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception 
 public Response processEndTransaction(TransactionInfo info) throws Exception 
 public Response processMessage(Message send) throws Exception 
 public Response processPrepareTransaction(TransactionInfo info) throws Exception 
 public Response processRemoveConnection(ConnectionId id,
    long lastDeliveredSequenceId) throws Exception 
 public Response processRemoveConsumer(ConsumerId id,
    long lastDeliveredSequenceId) 
 public Response processRemoveDestination(DestinationInfo info) 
 public Response processRemoveProducer(ProducerId id) 
 public Response processRemoveSession(SessionId id,
    long lastDeliveredSequenceId) 
 public Response processRollbackTransaction(TransactionInfo info) throws Exception 
 public  void restore(Transport transport) throws IOException 
 protected  void restoreConsumers(Transport transport,
    SessionState sessionState) throws IOException 
 protected  void restoreProducers(Transport transport,
    SessionState sessionState) throws IOException 
 protected  void restoreSessions(Transport transport,
    ConnectionState connectionState) throws IOException 
 protected  void restoreTempDestinations(Transport transport,
    ConnectionState connectionState) throws IOException 
 public  void setMaxCacheSize(int maxCacheSize) 
 public  void setRestoreConsumers(boolean restoreConsumers) 
 public  void setRestoreProducers(boolean restoreProducers) 
 public  void setRestoreSessions(boolean restoreSessions) 
 public  void setRestoreTransaction(boolean restoreTransaction) 
 public  void setTrackMessages(boolean trackMessages) 
 public  void setTrackTransactionProducers(boolean trackTransactionProducers) 
 public  void setTrackTransactions(boolean trackTransactions) 
 public Tracked track(Command command) throws IOException 
 public  void trackBack(Command command)