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< 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

activemq::state::ConnectionStateTracker::ConnectionStateTracker

(

)

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

virtual

Member Function Documentation

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

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

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

virtual

Implements activemq::state::CommandVisitor.

void activemq::state::ConnectionStateTracker::restore

(

decaf::lang::Pointer< transport::Transport >

transport

)

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

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

inline

Pointer<Tracked> activemq::state::ConnectionStateTracker::track

(

Pointer< Command >

command

)

void activemq::state::ConnectionStateTracker::trackBack

(

decaf::lang::Pointer< Command >

command

)

void activemq::state::ConnectionStateTracker::transportInterrupted

(

)

Friends And Related Function Documentation

friend class RemoveTransactionAction

friend

---

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

• src/main/activemq/state/ConnectionStateTracker.h