Package org.apache.activemq.state
Class CommandVisitorAdapter
- java.lang.Object
-
- org.apache.activemq.state.CommandVisitorAdapter
-
- All Implemented Interfaces:
CommandVisitor
- Direct Known Subclasses:
ConnectionStateTracker
public class CommandVisitorAdapter extends Object implements CommandVisitor
-
-
Constructor Summary
Constructors Constructor Description CommandVisitorAdapter()
-
Method Summary
-
-
-
Method Detail
-
processAddConnection
public Response processAddConnection(ConnectionInfo info) throws Exception
- Specified by:
processAddConnection
in interfaceCommandVisitor
- Throws:
Exception
-
processAddConsumer
public Response processAddConsumer(ConsumerInfo info) throws Exception
- Specified by:
processAddConsumer
in interfaceCommandVisitor
- Throws:
Exception
-
processAddDestination
public Response processAddDestination(DestinationInfo info) throws Exception
- Specified by:
processAddDestination
in interfaceCommandVisitor
- Throws:
Exception
-
processAddProducer
public Response processAddProducer(ProducerInfo info) throws Exception
- Specified by:
processAddProducer
in interfaceCommandVisitor
- Throws:
Exception
-
processAddSession
public Response processAddSession(SessionInfo info) throws Exception
- Specified by:
processAddSession
in interfaceCommandVisitor
- Throws:
Exception
-
processBeginTransaction
public Response processBeginTransaction(TransactionInfo info) throws Exception
- Specified by:
processBeginTransaction
in interfaceCommandVisitor
- Throws:
Exception
-
processBrokerInfo
public Response processBrokerInfo(BrokerInfo info) throws Exception
- Specified by:
processBrokerInfo
in interfaceCommandVisitor
- Throws:
Exception
-
processCommitTransactionOnePhase
public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception
- Specified by:
processCommitTransactionOnePhase
in interfaceCommandVisitor
- Throws:
Exception
-
processCommitTransactionTwoPhase
public Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception
- Specified by:
processCommitTransactionTwoPhase
in interfaceCommandVisitor
- Throws:
Exception
-
processEndTransaction
public Response processEndTransaction(TransactionInfo info) throws Exception
- Specified by:
processEndTransaction
in interfaceCommandVisitor
- Throws:
Exception
-
processFlush
public Response processFlush(FlushCommand command) throws Exception
- Specified by:
processFlush
in interfaceCommandVisitor
- Throws:
Exception
-
processForgetTransaction
public Response processForgetTransaction(TransactionInfo info) throws Exception
- Specified by:
processForgetTransaction
in interfaceCommandVisitor
- Throws:
Exception
-
processKeepAlive
public Response processKeepAlive(KeepAliveInfo info) throws Exception
- Specified by:
processKeepAlive
in interfaceCommandVisitor
- Throws:
Exception
-
processMessage
public Response processMessage(Message send) throws Exception
- Specified by:
processMessage
in interfaceCommandVisitor
- Throws:
Exception
-
processMessageAck
public Response processMessageAck(MessageAck ack) throws Exception
- Specified by:
processMessageAck
in interfaceCommandVisitor
- Throws:
Exception
-
processMessageDispatchNotification
public Response processMessageDispatchNotification(MessageDispatchNotification notification) throws Exception
- Specified by:
processMessageDispatchNotification
in interfaceCommandVisitor
- Throws:
Exception
-
processMessagePull
public Response processMessagePull(MessagePull pull) throws Exception
- Specified by:
processMessagePull
in interfaceCommandVisitor
- Throws:
Exception
-
processPrepareTransaction
public Response processPrepareTransaction(TransactionInfo info) throws Exception
- Specified by:
processPrepareTransaction
in interfaceCommandVisitor
- Throws:
Exception
-
processProducerAck
public Response processProducerAck(ProducerAck ack) throws Exception
- Specified by:
processProducerAck
in interfaceCommandVisitor
- Throws:
Exception
-
processRecoverTransactions
public Response processRecoverTransactions(TransactionInfo info) throws Exception
- Specified by:
processRecoverTransactions
in interfaceCommandVisitor
- Throws:
Exception
-
processRemoveConnection
public Response processRemoveConnection(ConnectionId id, long lastDeliveredSequenceId) throws Exception
- Specified by:
processRemoveConnection
in interfaceCommandVisitor
- Throws:
Exception
-
processRemoveConsumer
public Response processRemoveConsumer(ConsumerId id, long lastDeliveredSequenceId) throws Exception
- Specified by:
processRemoveConsumer
in interfaceCommandVisitor
- Throws:
Exception
-
processRemoveDestination
public Response processRemoveDestination(DestinationInfo info) throws Exception
- Specified by:
processRemoveDestination
in interfaceCommandVisitor
- Throws:
Exception
-
processRemoveProducer
public Response processRemoveProducer(ProducerId id) throws Exception
- Specified by:
processRemoveProducer
in interfaceCommandVisitor
- Throws:
Exception
-
processRemoveSession
public Response processRemoveSession(SessionId id, long lastDeliveredSequenceId) throws Exception
- Specified by:
processRemoveSession
in interfaceCommandVisitor
- Throws:
Exception
-
processRemoveSubscription
public Response processRemoveSubscription(RemoveSubscriptionInfo info) throws Exception
- Specified by:
processRemoveSubscription
in interfaceCommandVisitor
- Throws:
Exception
-
processRollbackTransaction
public Response processRollbackTransaction(TransactionInfo info) throws Exception
- Specified by:
processRollbackTransaction
in interfaceCommandVisitor
- Throws:
Exception
-
processShutdown
public Response processShutdown(ShutdownInfo info) throws Exception
- Specified by:
processShutdown
in interfaceCommandVisitor
- Throws:
Exception
-
processWireFormat
public Response processWireFormat(WireFormatInfo info) throws Exception
- Specified by:
processWireFormat
in interfaceCommandVisitor
- Throws:
Exception
-
processMessageDispatch
public Response processMessageDispatch(MessageDispatch dispatch) throws Exception
- Specified by:
processMessageDispatch
in interfaceCommandVisitor
- Throws:
Exception
-
processControlCommand
public Response processControlCommand(ControlCommand command) throws Exception
- Specified by:
processControlCommand
in interfaceCommandVisitor
- Throws:
Exception
-
processConnectionControl
public Response processConnectionControl(ConnectionControl control) throws Exception
- Specified by:
processConnectionControl
in interfaceCommandVisitor
- Throws:
Exception
-
processConnectionError
public Response processConnectionError(ConnectionError error) throws Exception
- Specified by:
processConnectionError
in interfaceCommandVisitor
- Throws:
Exception
-
processConsumerControl
public Response processConsumerControl(ConsumerControl control) throws Exception
- Specified by:
processConsumerControl
in interfaceCommandVisitor
- Throws:
Exception
-
processBrokerSubscriptionInfo
public Response processBrokerSubscriptionInfo(BrokerSubscriptionInfo info) throws Exception
- Specified by:
processBrokerSubscriptionInfo
in interfaceCommandVisitor
- Throws:
Exception
-
-