activemq-cpp-3.9.5
activemq::state::ConnectionStateTracker Class Reference

#include <src/main/activemq/state/ConnectionStateTracker.h>

Inheritance diagram for activemq::state::ConnectionStateTracker:

Public Member Functions

 ConnectionStateTracker ()
 
virtual ~ConnectionStateTracker ()
 
Pointer< Trackedtrack (Pointer< Command > command)
 
void trackBack (decaf::lang::Pointer< Command > command)
 
void restore (decaf::lang::Pointer< transport::Transport > transport)
 
void connectionInterruptProcessingComplete (transport::Transport *transport, decaf::lang::Pointer< ConnectionId > connectionId)
 
void transportInterrupted ()
 
virtual decaf::lang::Pointer< CommandprocessDestinationInfo (DestinationInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessRemoveDestination (DestinationInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessProducerInfo (ProducerInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessRemoveProducer (ProducerId *id)
 
virtual decaf::lang::Pointer< CommandprocessConsumerInfo (ConsumerInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessRemoveConsumer (ConsumerId *id)
 
virtual decaf::lang::Pointer< CommandprocessSessionInfo (SessionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessRemoveSession (SessionId *id)
 
virtual decaf::lang::Pointer< CommandprocessConnectionInfo (ConnectionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessRemoveConnection (ConnectionId *id)
 
virtual decaf::lang::Pointer< CommandprocessMessage (Message *message)
 
virtual decaf::lang::Pointer< CommandprocessBeginTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessPrepareTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessCommitTransactionOnePhase (TransactionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessCommitTransactionTwoPhase (TransactionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessRollbackTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessEndTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< CommandprocessMessagePull (MessagePull *pull)
 
bool isRestoreConsumers () const
 
void setRestoreConsumers (bool restoreConsumers)
 
bool isRestoreProducers () const
 
void setRestoreProducers (bool restoreProducers)
 
bool isRestoreSessions () const
 
void setRestoreSessions (bool restoreSessions)
 
bool isTrackTransactions () const
 
void setTrackTransactions (bool trackTransactions)
 
bool isRestoreTransaction () const
 
void setRestoreTransaction (bool restoreTransaction)
 
bool isTrackMessages () const
 
void setTrackMessages (bool trackMessages)
 
int getMaxMessageCacheSize () const
 
void setMaxMessageCacheSize (int maxMessageCacheSize)
 
int getMaxMessagePullCacheSize () const
 
void setMaxMessagePullCacheSize (int maxMessagePullCacheSize)
 
bool isTrackTransactionProducers () const
 
void setTrackTransactionProducers (bool trackTransactionProducers)
 
- Public Member Functions inherited from activemq::state::CommandVisitorAdapter
virtual ~CommandVisitorAdapter ()
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveConnection (commands::ConnectionId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveSession (commands::SessionId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveProducer (commands::ProducerId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveConsumer (commands::ConsumerId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessDestinationInfo (commands::DestinationInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveDestination (commands::DestinationInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveSubscriptionInfo (commands::RemoveSubscriptionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessMessage (commands::Message *send AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessMessageAck (commands::MessageAck *ack AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessMessagePull (commands::MessagePull *pull AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessBeginTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessPrepareTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessCommitTransactionOnePhase (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessCommitTransactionTwoPhase (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessRollbackTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessWireFormat (commands::WireFormatInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessKeepAliveInfo (commands::KeepAliveInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessShutdownInfo (commands::ShutdownInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessFlushCommand (commands::FlushCommand *command AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessBrokerInfo (commands::BrokerInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessRecoverTransactions (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessForgetTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessEndTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessMessageDispatchNotification (commands::MessageDispatchNotification *notification AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessProducerAck (commands::ProducerAck *ack AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessMessageDispatch (commands::MessageDispatch *dispatch AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessControlCommand (commands::ControlCommand *command AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessConnectionError (commands::ConnectionError *error AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessConnectionControl (commands::ConnectionControl *control AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessConsumerControl (commands::ConsumerControl *control AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessBrokerError (commands::BrokerError *error AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessReplayCommand (commands::ReplayCommand *replay AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessResponse (commands::Response *response AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessConnectionInfo (commands::ConnectionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessSessionInfo (commands::SessionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessProducerInfo (commands::ProducerInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessConsumerInfo (commands::ConsumerInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::CommandprocessTransactionInfo (commands::TransactionInfo *info)
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveInfo (commands::RemoveInfo *info)
 
- Public Member Functions inherited from activemq::state::CommandVisitor
virtual ~CommandVisitor ()
 
virtual decaf::lang::Pointer< commands::CommandprocessRemoveSubscriptionInfo (commands::RemoveSubscriptionInfo *info)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessMessageAck (commands::MessageAck *ack)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessWireFormat (commands::WireFormatInfo *info)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessKeepAliveInfo (commands::KeepAliveInfo *info)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessShutdownInfo (commands::ShutdownInfo *info)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessFlushCommand (commands::FlushCommand *command)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessBrokerInfo (commands::BrokerInfo *info)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessRecoverTransactions (commands::TransactionInfo *info)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessForgetTransaction (commands::TransactionInfo *info)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessMessageDispatchNotification (commands::MessageDispatchNotification *notification)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessProducerAck (commands::ProducerAck *ack)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessMessageDispatch (commands::MessageDispatch *dispatch)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessControlCommand (commands::ControlCommand *command)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessConnectionError (commands::ConnectionError *error)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessConnectionControl (commands::ConnectionControl *control)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessConsumerControl (commands::ConsumerControl *control)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessBrokerError (commands::BrokerError *error)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessReplayCommand (commands::ReplayCommand *replay)=0
 
virtual decaf::lang::Pointer< commands::CommandprocessResponse (commands::Response *response)=0
 

Friends

class RemoveTransactionAction
 

Constructor & Destructor Documentation

◆ ConnectionStateTracker()

activemq::state::ConnectionStateTracker::ConnectionStateTracker ( )

◆ ~ConnectionStateTracker()

virtual activemq::state::ConnectionStateTracker::~ConnectionStateTracker ( )
virtual

Member Function Documentation

◆ connectionInterruptProcessingComplete()

void activemq::state::ConnectionStateTracker::connectionInterruptProcessingComplete ( transport::Transport * transport,
decaf::lang::Pointer< ConnectionId > connectionId )

◆ getMaxMessageCacheSize()

int activemq::state::ConnectionStateTracker::getMaxMessageCacheSize ( ) const
inline

◆ getMaxMessagePullCacheSize()

int activemq::state::ConnectionStateTracker::getMaxMessagePullCacheSize ( ) const
inline

◆ isRestoreConsumers()

bool activemq::state::ConnectionStateTracker::isRestoreConsumers ( ) const
inline

◆ isRestoreProducers()

bool activemq::state::ConnectionStateTracker::isRestoreProducers ( ) const
inline

◆ isRestoreSessions()

bool activemq::state::ConnectionStateTracker::isRestoreSessions ( ) const
inline

◆ isRestoreTransaction()

bool activemq::state::ConnectionStateTracker::isRestoreTransaction ( ) const
inline

◆ isTrackMessages()

bool activemq::state::ConnectionStateTracker::isTrackMessages ( ) const
inline

◆ isTrackTransactionProducers()

bool activemq::state::ConnectionStateTracker::isTrackTransactionProducers ( ) const
inline

◆ isTrackTransactions()

bool activemq::state::ConnectionStateTracker::isTrackTransactions ( ) const
inline

◆ processBeginTransaction()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processBeginTransaction ( TransactionInfo * info)
virtual

◆ processCommitTransactionOnePhase()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processCommitTransactionOnePhase ( TransactionInfo * info)
virtual

◆ processCommitTransactionTwoPhase()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processCommitTransactionTwoPhase ( TransactionInfo * info)
virtual

◆ processConnectionInfo()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processConnectionInfo ( ConnectionInfo * info)
virtual

◆ processConsumerInfo()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processConsumerInfo ( ConsumerInfo * info)
virtual

◆ processDestinationInfo()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processDestinationInfo ( DestinationInfo * info)
virtual

◆ processEndTransaction()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processEndTransaction ( TransactionInfo * info)
virtual

◆ processMessage()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processMessage ( Message * message)
virtual

◆ processMessagePull()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processMessagePull ( MessagePull * pull)
virtual

◆ processPrepareTransaction()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processPrepareTransaction ( TransactionInfo * info)
virtual

◆ processProducerInfo()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processProducerInfo ( ProducerInfo * info)
virtual

◆ processRemoveConnection()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processRemoveConnection ( ConnectionId * id)
virtual

◆ processRemoveConsumer()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processRemoveConsumer ( ConsumerId * id)
virtual

◆ processRemoveDestination()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processRemoveDestination ( DestinationInfo * info)
virtual

◆ processRemoveProducer()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processRemoveProducer ( ProducerId * id)
virtual

◆ processRemoveSession()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processRemoveSession ( SessionId * id)
virtual

◆ processRollbackTransaction()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processRollbackTransaction ( TransactionInfo * info)
virtual

◆ processSessionInfo()

virtual decaf::lang::Pointer< Command > activemq::state::ConnectionStateTracker::processSessionInfo ( SessionInfo * info)
virtual

◆ restore()

void activemq::state::ConnectionStateTracker::restore ( decaf::lang::Pointer< transport::Transport > transport)

◆ setMaxMessageCacheSize()

void activemq::state::ConnectionStateTracker::setMaxMessageCacheSize ( int maxMessageCacheSize)
inline

◆ setMaxMessagePullCacheSize()

void activemq::state::ConnectionStateTracker::setMaxMessagePullCacheSize ( int maxMessagePullCacheSize)
inline

◆ setRestoreConsumers()

void activemq::state::ConnectionStateTracker::setRestoreConsumers ( bool restoreConsumers)
inline

◆ setRestoreProducers()

void activemq::state::ConnectionStateTracker::setRestoreProducers ( bool restoreProducers)
inline

◆ setRestoreSessions()

void activemq::state::ConnectionStateTracker::setRestoreSessions ( bool restoreSessions)
inline

◆ setRestoreTransaction()

void activemq::state::ConnectionStateTracker::setRestoreTransaction ( bool restoreTransaction)
inline

◆ setTrackMessages()

void activemq::state::ConnectionStateTracker::setTrackMessages ( bool trackMessages)
inline

◆ setTrackTransactionProducers()

void activemq::state::ConnectionStateTracker::setTrackTransactionProducers ( bool trackTransactionProducers)
inline

◆ setTrackTransactions()

void activemq::state::ConnectionStateTracker::setTrackTransactions ( bool trackTransactions)
inline

◆ track()

Pointer< Tracked > activemq::state::ConnectionStateTracker::track ( Pointer< Command > command)

◆ trackBack()

void activemq::state::ConnectionStateTracker::trackBack ( decaf::lang::Pointer< Command > command)

◆ transportInterrupted()

void activemq::state::ConnectionStateTracker::transportInterrupted ( )

Friends And Related Symbol Documentation

◆ RemoveTransactionAction

friend class RemoveTransactionAction
friend

The documentation for this class was generated from the following file: