org.apache.activemq.state

Interface CommandVisitor

All Known Implementing Classes:

CommandVisitorAdapter, ConnectionStateTracker, ManagedTransportConnection, TransportConnection

public interface CommandVisitor

Method Summary

Methods

Modifier and Type	Method and Description
Response	processAddConnection(ConnectionInfo info)
Response	processAddConsumer(ConsumerInfo info)
Response	processAddDestination(DestinationInfo info)
Response	processAddProducer(ProducerInfo info)
Response	processAddSession(SessionInfo info)
Response	processBeginTransaction(TransactionInfo info)
Response	processBrokerInfo(BrokerInfo info)
Response	processCommitTransactionOnePhase(TransactionInfo info)
Response	processCommitTransactionTwoPhase(TransactionInfo info)
Response	processConnectionControl(ConnectionControl control)
Response	processConnectionError(ConnectionError error)
Response	processConsumerControl(ConsumerControl control)
Response	processControlCommand(ControlCommand command)
Response	processEndTransaction(TransactionInfo info)
Response	processFlush(FlushCommand command)
Response	processForgetTransaction(TransactionInfo info)
Response	processKeepAlive(KeepAliveInfo info)
Response	processMessage(Message send)
Response	processMessageAck(MessageAck ack)
Response	processMessageDispatch(MessageDispatch dispatch)
Response	processMessageDispatchNotification(MessageDispatchNotification notification)
Response	processMessagePull(MessagePull pull)
Response	processPrepareTransaction(TransactionInfo info)
Response	processProducerAck(ProducerAck ack)
Response	processRecoverTransactions(TransactionInfo info)
Response	processRemoveConnection(ConnectionId id, long lastDeliveredSequenceId)
Response	processRemoveConsumer(ConsumerId id, long lastDeliveredSequenceId)
Response	processRemoveDestination(DestinationInfo info)
Response	processRemoveProducer(ProducerId id)
Response	processRemoveSession(SessionId id, long lastDeliveredSequenceId)
Response	processRemoveSubscription(RemoveSubscriptionInfo info)
Response	processRollbackTransaction(TransactionInfo info)
Response	processShutdown(ShutdownInfo info)
Response	processWireFormat(WireFormatInfo info)

Method Detail

processAddConnection

Response processAddConnection(ConnectionInfo info)
                              throws java.lang.Exception

Throws:

java.lang.Exception

processAddSession

Response processAddSession(SessionInfo info)
                           throws java.lang.Exception

Throws:

java.lang.Exception

processAddProducer

Response processAddProducer(ProducerInfo info)
                            throws java.lang.Exception

Throws:

java.lang.Exception

processAddConsumer

Response processAddConsumer(ConsumerInfo info)
                            throws java.lang.Exception

Throws:

java.lang.Exception

processRemoveConnection

Response processRemoveConnection(ConnectionId id,
                               long lastDeliveredSequenceId)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

processRemoveSession

Response processRemoveSession(SessionId id,
                            long lastDeliveredSequenceId)
                              throws java.lang.Exception

Throws:

java.lang.Exception

processRemoveProducer

Response processRemoveProducer(ProducerId id)
                               throws java.lang.Exception

Throws:

java.lang.Exception

processRemoveConsumer

Response processRemoveConsumer(ConsumerId id,
                             long lastDeliveredSequenceId)
                               throws java.lang.Exception

Throws:

java.lang.Exception

processAddDestination

Response processAddDestination(DestinationInfo info)
                               throws java.lang.Exception

Throws:

java.lang.Exception

processRemoveDestination

Response processRemoveDestination(DestinationInfo info)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

processRemoveSubscription

Response processRemoveSubscription(RemoveSubscriptionInfo info)
                                   throws java.lang.Exception

Throws:

java.lang.Exception

processMessage

Response processMessage(Message send)
                        throws java.lang.Exception

Throws:

java.lang.Exception

processMessageAck

Response processMessageAck(MessageAck ack)
                           throws java.lang.Exception

Throws:

java.lang.Exception

processMessagePull

Response processMessagePull(MessagePull pull)
                            throws java.lang.Exception

Throws:

java.lang.Exception

processBeginTransaction

Response processBeginTransaction(TransactionInfo info)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

processPrepareTransaction

Response processPrepareTransaction(TransactionInfo info)
                                   throws java.lang.Exception

Throws:

java.lang.Exception

processCommitTransactionOnePhase

Response processCommitTransactionOnePhase(TransactionInfo info)
                                          throws java.lang.Exception

Throws:

java.lang.Exception

processCommitTransactionTwoPhase

Response processCommitTransactionTwoPhase(TransactionInfo info)
                                          throws java.lang.Exception

Throws:

java.lang.Exception

processRollbackTransaction

Response processRollbackTransaction(TransactionInfo info)
                                    throws java.lang.Exception

Throws:

java.lang.Exception

processWireFormat

Response processWireFormat(WireFormatInfo info)
                           throws java.lang.Exception

Throws:

java.lang.Exception

processKeepAlive

Response processKeepAlive(KeepAliveInfo info)
                          throws java.lang.Exception

Throws:

java.lang.Exception

processShutdown

Response processShutdown(ShutdownInfo info)
                         throws java.lang.Exception

Throws:

java.lang.Exception

processFlush

Response processFlush(FlushCommand command)
                      throws java.lang.Exception

Throws:

java.lang.Exception

processBrokerInfo

Response processBrokerInfo(BrokerInfo info)
                           throws java.lang.Exception

Throws:

java.lang.Exception

processRecoverTransactions

Response processRecoverTransactions(TransactionInfo info)
                                    throws java.lang.Exception

Throws:

java.lang.Exception

processForgetTransaction

Response processForgetTransaction(TransactionInfo info)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

processEndTransaction

Response processEndTransaction(TransactionInfo info)
                               throws java.lang.Exception

Throws:

java.lang.Exception

processMessageDispatchNotification

Response processMessageDispatchNotification(MessageDispatchNotification notification)
                                            throws java.lang.Exception

Throws:

java.lang.Exception

processProducerAck

Response processProducerAck(ProducerAck ack)
                            throws java.lang.Exception

Throws:

java.lang.Exception

processMessageDispatch

Response processMessageDispatch(MessageDispatch dispatch)
                                throws java.lang.Exception

Throws:

java.lang.Exception

processControlCommand

Response processControlCommand(ControlCommand command)
                               throws java.lang.Exception

Throws:

java.lang.Exception

processConnectionError

Response processConnectionError(ConnectionError error)
                                throws java.lang.Exception

Throws:

java.lang.Exception

processConnectionControl

Response processConnectionControl(ConnectionControl control)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

processConsumerControl

Response processConsumerControl(ConsumerControl control)
                                throws java.lang.Exception

Throws:

java.lang.Exception