activemq-cpp-3.8.2
Public Member Functions | Friends
activemq::state::ConnectionStateTracker Class Reference

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

Inheritance diagram for activemq::state::ConnectionStateTracker:
Inheritance graph
[legend]

Public Member Functions

 ConnectionStateTracker ()
 
virtual ~ConnectionStateTracker ()
 
Pointer< Tracked > track (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< Command > processDestinationInfo (DestinationInfo *info)
 
virtual decaf::lang::Pointer< Command > processRemoveDestination (DestinationInfo *info)
 
virtual decaf::lang::Pointer< Command > processProducerInfo (ProducerInfo *info)
 
virtual decaf::lang::Pointer< Command > processRemoveProducer (ProducerId *id)
 
virtual decaf::lang::Pointer< Command > processConsumerInfo (ConsumerInfo *info)
 
virtual decaf::lang::Pointer< Command > processRemoveConsumer (ConsumerId *id)
 
virtual decaf::lang::Pointer< Command > processSessionInfo (SessionInfo *info)
 
virtual decaf::lang::Pointer< Command > processRemoveSession (SessionId *id)
 
virtual decaf::lang::Pointer< Command > processConnectionInfo (ConnectionInfo *info)
 
virtual decaf::lang::Pointer< Command > processRemoveConnection (ConnectionId *id)
 
virtual decaf::lang::Pointer< Command > processMessage (Message *message)
 
virtual decaf::lang::Pointer< Command > processBeginTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< Command > processPrepareTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< Command > processCommitTransactionOnePhase (TransactionInfo *info)
 
virtual decaf::lang::Pointer< Command > processCommitTransactionTwoPhase (TransactionInfo *info)
 
virtual decaf::lang::Pointer< Command > processRollbackTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< Command > processEndTransaction (TransactionInfo *info)
 
virtual decaf::lang::Pointer< Command > processMessagePull (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::Command > processRemoveConnection (commands::ConnectionId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processRemoveSession (commands::SessionId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processRemoveProducer (commands::ProducerId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processRemoveConsumer (commands::ConsumerId *id AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processDestinationInfo (commands::DestinationInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processRemoveDestination (commands::DestinationInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processRemoveSubscriptionInfo (commands::RemoveSubscriptionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processMessage (commands::Message *send AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processMessageAck (commands::MessageAck *ack AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processMessagePull (commands::MessagePull *pull AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processBeginTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processPrepareTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processCommitTransactionOnePhase (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processCommitTransactionTwoPhase (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processRollbackTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processWireFormat (commands::WireFormatInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processKeepAliveInfo (commands::KeepAliveInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processShutdownInfo (commands::ShutdownInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processFlushCommand (commands::FlushCommand *command AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processBrokerInfo (commands::BrokerInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processRecoverTransactions (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processForgetTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processEndTransaction (commands::TransactionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processMessageDispatchNotification (commands::MessageDispatchNotification *notification AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processProducerAck (commands::ProducerAck *ack AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processMessageDispatch (commands::MessageDispatch *dispatch AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processControlCommand (commands::ControlCommand *command AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processConnectionError (commands::ConnectionError *error AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processConnectionControl (commands::ConnectionControl *control AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processConsumerControl (commands::ConsumerControl *control AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processBrokerError (commands::BrokerError *error AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processReplayCommand (commands::ReplayCommand *replay AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processResponse (commands::Response *response AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processConnectionInfo (commands::ConnectionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processSessionInfo (commands::SessionInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processProducerInfo (commands::ProducerInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processConsumerInfo (commands::ConsumerInfo *info AMQCPP_UNUSED)
 
virtual decaf::lang::Pointer< commands::Command > processTransactionInfo (commands::TransactionInfo *info)
 
virtual decaf::lang::Pointer< commands::Command > processRemoveInfo (commands::RemoveInfo *info)
 
- Public Member Functions inherited from activemq::state::CommandVisitor
virtual ~CommandVisitor ()
 
virtual decaf::lang::Pointer< commands::Command > processRemoveSubscriptionInfo (commands::RemoveSubscriptionInfo *info)=0
 
virtual decaf::lang::Pointer< commands::Command > processMessageAck (commands::MessageAck *ack)=0
 
virtual decaf::lang::Pointer< commands::Command > processWireFormat (commands::WireFormatInfo *info)=0
 
virtual decaf::lang::Pointer< commands::Command > processKeepAliveInfo (commands::KeepAliveInfo *info)=0
 
virtual decaf::lang::Pointer< commands::Command > processShutdownInfo (commands::ShutdownInfo *info)=0
 
virtual decaf::lang::Pointer< commands::Command > processFlushCommand (commands::FlushCommand *command)=0
 
virtual decaf::lang::Pointer< commands::Command > processBrokerInfo (commands::BrokerInfo *info)=0
 
virtual decaf::lang::Pointer< commands::Command > processRecoverTransactions (commands::TransactionInfo *info)=0
 
virtual decaf::lang::Pointer< commands::Command > processForgetTransaction (commands::TransactionInfo *info)=0
 
virtual decaf::lang::Pointer< commands::Command > processMessageDispatchNotification (commands::MessageDispatchNotification *notification)=0
 
virtual decaf::lang::Pointer< commands::Command > processProducerAck (commands::ProducerAck *ack)=0
 
virtual decaf::lang::Pointer< commands::Command > processMessageDispatch (commands::MessageDispatch *dispatch)=0
 
virtual decaf::lang::Pointer< commands::Command > processControlCommand (commands::ControlCommand *command)=0
 
virtual decaf::lang::Pointer< commands::Command > processConnectionError (commands::ConnectionError *error)=0
 
virtual decaf::lang::Pointer< commands::Command > processConnectionControl (commands::ConnectionControl *control)=0
 
virtual decaf::lang::Pointer< commands::Command > processConsumerControl (commands::ConsumerControl *control)=0
 
virtual decaf::lang::Pointer< commands::Command > processBrokerError (commands::BrokerError *error)=0
 
virtual decaf::lang::Pointer< commands::Command > processReplayCommand (commands::ReplayCommand *replay)=0
 
virtual decaf::lang::Pointer< commands::Command > processResponse (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

Implements activemq::state::CommandVisitor.

◆ processCommitTransactionOnePhase()

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

Implements activemq::state::CommandVisitor.

◆ processCommitTransactionTwoPhase()

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

Implements activemq::state::CommandVisitor.

◆ processConnectionInfo()

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

Implements activemq::state::CommandVisitor.

◆ processConsumerInfo()

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

Implements activemq::state::CommandVisitor.

◆ processDestinationInfo()

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

Implements activemq::state::CommandVisitor.

◆ processEndTransaction()

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

Implements activemq::state::CommandVisitor.

◆ processMessage()

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

Implements activemq::state::CommandVisitor.

◆ processMessagePull()

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

Implements activemq::state::CommandVisitor.

◆ processPrepareTransaction()

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

Implements activemq::state::CommandVisitor.

◆ processProducerInfo()

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

Implements activemq::state::CommandVisitor.

◆ processRemoveConnection()

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

Implements activemq::state::CommandVisitor.

◆ processRemoveConsumer()

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

Implements activemq::state::CommandVisitor.

◆ processRemoveDestination()

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

Implements activemq::state::CommandVisitor.

◆ processRemoveProducer()

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

Implements activemq::state::CommandVisitor.

◆ processRemoveSession()

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

Implements activemq::state::CommandVisitor.

◆ processRollbackTransaction()

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

Implements activemq::state::CommandVisitor.

◆ processSessionInfo()

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

Implements activemq::state::CommandVisitor.

◆ 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 Function Documentation

◆ RemoveTransactionAction

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