org.apache.activemq.state
Interface CommandVisitor
- All Known Implementing Classes:
- CommandVisitorAdapter, ConnectionStateTracker, ManagedTransportConnection, TransportConnection
public interface CommandVisitor
processAddConnection
Response processAddConnection(ConnectionInfo info)
throws Exception
- Throws:
Exception
processAddSession
Response processAddSession(SessionInfo info)
throws Exception
- Throws:
Exception
processAddProducer
Response processAddProducer(ProducerInfo info)
throws Exception
- Throws:
Exception
processAddConsumer
Response processAddConsumer(ConsumerInfo info)
throws Exception
- Throws:
Exception
processRemoveConnection
Response processRemoveConnection(ConnectionId id,
long lastDeliveredSequenceId)
throws Exception
- Throws:
Exception
processRemoveSession
Response processRemoveSession(SessionId id,
long lastDeliveredSequenceId)
throws Exception
- Throws:
Exception
processRemoveProducer
Response processRemoveProducer(ProducerId id)
throws Exception
- Throws:
Exception
processRemoveConsumer
Response processRemoveConsumer(ConsumerId id,
long lastDeliveredSequenceId)
throws Exception
- Throws:
Exception
processAddDestination
Response processAddDestination(DestinationInfo info)
throws Exception
- Throws:
Exception
processRemoveDestination
Response processRemoveDestination(DestinationInfo info)
throws Exception
- Throws:
Exception
processRemoveSubscription
Response processRemoveSubscription(RemoveSubscriptionInfo info)
throws Exception
- Throws:
Exception
processMessage
Response processMessage(Message send)
throws Exception
- Throws:
Exception
processMessageAck
Response processMessageAck(MessageAck ack)
throws Exception
- Throws:
Exception
processMessagePull
Response processMessagePull(MessagePull pull)
throws Exception
- Throws:
Exception
processBeginTransaction
Response processBeginTransaction(TransactionInfo info)
throws Exception
- Throws:
Exception
processPrepareTransaction
Response processPrepareTransaction(TransactionInfo info)
throws Exception
- Throws:
Exception
processCommitTransactionOnePhase
Response processCommitTransactionOnePhase(TransactionInfo info)
throws Exception
- Throws:
Exception
processCommitTransactionTwoPhase
Response processCommitTransactionTwoPhase(TransactionInfo info)
throws Exception
- Throws:
Exception
processRollbackTransaction
Response processRollbackTransaction(TransactionInfo info)
throws Exception
- Throws:
Exception
processWireFormat
Response processWireFormat(WireFormatInfo info)
throws Exception
- Throws:
Exception
processKeepAlive
Response processKeepAlive(KeepAliveInfo info)
throws Exception
- Throws:
Exception
processShutdown
Response processShutdown(ShutdownInfo info)
throws Exception
- Throws:
Exception
processFlush
Response processFlush(FlushCommand command)
throws Exception
- Throws:
Exception
processBrokerInfo
Response processBrokerInfo(BrokerInfo info)
throws Exception
- Throws:
Exception
processRecoverTransactions
Response processRecoverTransactions(TransactionInfo info)
throws Exception
- Throws:
Exception
processForgetTransaction
Response processForgetTransaction(TransactionInfo info)
throws Exception
- Throws:
Exception
processEndTransaction
Response processEndTransaction(TransactionInfo info)
throws Exception
- Throws:
Exception
processMessageDispatchNotification
Response processMessageDispatchNotification(MessageDispatchNotification notification)
throws Exception
- Throws:
Exception
processProducerAck
Response processProducerAck(ProducerAck ack)
throws Exception
- Throws:
Exception
processMessageDispatch
Response processMessageDispatch(MessageDispatch dispatch)
throws Exception
- Throws:
Exception
processControlCommand
Response processControlCommand(ControlCommand command)
throws Exception
- Throws:
Exception
processConnectionError
Response processConnectionError(ConnectionError error)
throws Exception
- Throws:
Exception
processConnectionControl
Response processConnectionControl(ConnectionControl control)
throws Exception
- Throws:
Exception
processConsumerControl
Response processConsumerControl(ConsumerControl control)
throws Exception
- Throws:
Exception
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.