00001 /* 00002 * Licensed to the Apache Software Foundation (ASF) under one or more 00003 * contributor license agreements. See the NOTICE file distributed with 00004 * this work for additional information regarding copyright ownership. 00005 * The ASF licenses this file to You under the Apache License, Version 2.0 00006 * (the "License"); you may not use this file except in compliance with 00007 * the License. You may obtain a copy of the License at 00008 * 00009 * http://www.apache.org/licenses/LICENSE-2.0 00010 * 00011 * Unless required by applicable law or agreed to in writing, software 00012 * distributed under the License is distributed on an "AS IS" BASIS, 00013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 00014 * See the License for the specific language governing permissions and 00015 * limitations under the License. 00016 */ 00017 00018 #ifndef _ACTIVEMQ_STATE_COMMANDVISITOR_H_ 00019 #define _ACTIVEMQ_STATE_COMMANDVISITOR_H_ 00020 00021 #include <activemq/util/Config.h> 00022 #include <activemq/exceptions/ActiveMQException.h> 00023 #include <decaf/lang/Pointer.h> 00024 00025 namespace activemq { 00026 namespace commands { 00027 class Command; 00028 class ConnectionInfo; 00029 class SessionInfo; 00030 class ProducerInfo; 00031 class ConnectionId; 00032 class SessionId; 00033 class ProducerId; 00034 class ConsumerId; 00035 class ConsumerInfo; 00036 class DestinationInfo; 00037 class RemoveSubscriptionInfo; 00038 class Message; 00039 class MessageAck; 00040 class MessagePull; 00041 class TransactionInfo; 00042 class WireFormatInfo; 00043 class ProducerAck; 00044 class MessageDispatch; 00045 class MessageDispatchNotification; 00046 class ControlCommand; 00047 class ConnectionError; 00048 class ConnectionControl; 00049 class ConsumerControl; 00050 class ShutdownInfo; 00051 class KeepAliveInfo; 00052 class FlushCommand; 00053 class BrokerError; 00054 class BrokerInfo; 00055 class RemoveInfo; 00056 class Response; 00057 class ReplayCommand; 00058 } 00059 namespace state { 00060 00069 class AMQCPP_API CommandVisitor { 00070 public: 00071 00072 virtual ~CommandVisitor(); 00073 00074 virtual decaf::lang::Pointer<commands::Command> processTransactionInfo(commands::TransactionInfo* info) = 0; 00075 00076 virtual decaf::lang::Pointer<commands::Command> processRemoveInfo(commands::RemoveInfo* info) = 0; 00077 00078 virtual decaf::lang::Pointer<commands::Command> processConnectionInfo(commands::ConnectionInfo* info) = 0; 00079 00080 virtual decaf::lang::Pointer<commands::Command> processSessionInfo(commands::SessionInfo* info) = 0; 00081 00082 virtual decaf::lang::Pointer<commands::Command> processProducerInfo(commands::ProducerInfo* info) = 0; 00083 00084 virtual decaf::lang::Pointer<commands::Command> processConsumerInfo(commands::ConsumerInfo* info) = 0; 00085 00086 virtual decaf::lang::Pointer<commands::Command> processRemoveConnection(commands::ConnectionId* id) = 0; 00087 00088 virtual decaf::lang::Pointer<commands::Command> processRemoveSession(commands::SessionId* id) = 0; 00089 00090 virtual decaf::lang::Pointer<commands::Command> processRemoveProducer(commands::ProducerId* id) = 0; 00091 00092 virtual decaf::lang::Pointer<commands::Command> processRemoveConsumer(commands::ConsumerId* id) = 0; 00093 00094 virtual decaf::lang::Pointer<commands::Command> processDestinationInfo(commands::DestinationInfo* info) = 0; 00095 00096 virtual decaf::lang::Pointer<commands::Command> processRemoveDestination(commands::DestinationInfo* info) = 0; 00097 00098 virtual decaf::lang::Pointer<commands::Command> processRemoveSubscriptionInfo(commands::RemoveSubscriptionInfo* info) = 0; 00099 00100 virtual decaf::lang::Pointer<commands::Command> processMessage(commands::Message* send) = 0; 00101 00102 virtual decaf::lang::Pointer<commands::Command> processMessageAck(commands::MessageAck* ack) = 0; 00103 00104 virtual decaf::lang::Pointer<commands::Command> processMessagePull(commands::MessagePull* pull) = 0; 00105 00106 virtual decaf::lang::Pointer<commands::Command> processBeginTransaction(commands::TransactionInfo* info) = 0; 00107 00108 virtual decaf::lang::Pointer<commands::Command> processPrepareTransaction(commands::TransactionInfo* info) = 0; 00109 00110 virtual decaf::lang::Pointer<commands::Command> processCommitTransactionOnePhase(commands::TransactionInfo* info) = 0; 00111 00112 virtual decaf::lang::Pointer<commands::Command> processCommitTransactionTwoPhase(commands::TransactionInfo* info) = 0; 00113 00114 virtual decaf::lang::Pointer<commands::Command> processRollbackTransaction(commands::TransactionInfo* info) = 0; 00115 00116 virtual decaf::lang::Pointer<commands::Command> processWireFormat(commands::WireFormatInfo* info) = 0; 00117 00118 virtual decaf::lang::Pointer<commands::Command> processKeepAliveInfo(commands::KeepAliveInfo* info) = 0; 00119 00120 virtual decaf::lang::Pointer<commands::Command> processShutdownInfo(commands::ShutdownInfo* info) = 0; 00121 00122 virtual decaf::lang::Pointer<commands::Command> processFlushCommand(commands::FlushCommand* command) = 0; 00123 00124 virtual decaf::lang::Pointer<commands::Command> processBrokerInfo(commands::BrokerInfo* info) = 0; 00125 00126 virtual decaf::lang::Pointer<commands::Command> processRecoverTransactions(commands::TransactionInfo* info) = 0; 00127 00128 virtual decaf::lang::Pointer<commands::Command> processForgetTransaction(commands::TransactionInfo* info) = 0; 00129 00130 virtual decaf::lang::Pointer<commands::Command> processEndTransaction(commands::TransactionInfo* info) = 0; 00131 00132 virtual decaf::lang::Pointer<commands::Command> processMessageDispatchNotification(commands::MessageDispatchNotification* notification) = 0; 00133 00134 virtual decaf::lang::Pointer<commands::Command> processProducerAck(commands::ProducerAck* ack) = 0; 00135 00136 virtual decaf::lang::Pointer<commands::Command> processMessageDispatch(commands::MessageDispatch* dispatch) = 0; 00137 00138 virtual decaf::lang::Pointer<commands::Command> processControlCommand(commands::ControlCommand* command) = 0; 00139 00140 virtual decaf::lang::Pointer<commands::Command> processConnectionError(commands::ConnectionError* error) = 0; 00141 00142 virtual decaf::lang::Pointer<commands::Command> processConnectionControl(commands::ConnectionControl* control) = 0; 00143 00144 virtual decaf::lang::Pointer<commands::Command> processConsumerControl(commands::ConsumerControl* control) = 0; 00145 00146 virtual decaf::lang::Pointer<commands::Command> processBrokerError(commands::BrokerError* error) = 0; 00147 00148 virtual decaf::lang::Pointer<commands::Command> processReplayCommand(commands::ReplayCommand* replay) = 0; 00149 00150 virtual decaf::lang::Pointer<commands::Command> processResponse(commands::Response* response) = 0; 00151 00152 }; 00153 00154 }} 00155 00156 #endif /*_ACTIVEMQ_STATE_COMMANDVISITOR_H_*/
1.6.1