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_COMMANDVISITORADAPTER_H_ 00019 #define _ACTIVEMQ_STATE_COMMANDVISITORADAPTER_H_ 00020 00021 #include <activemq/util/Config.h> 00022 00023 #include <activemq/state/CommandVisitor.h> 00024 #include <activemq/core/ActiveMQConstants.h> 00025 00026 #include <activemq/commands/ConnectionInfo.h> 00027 #include <activemq/commands/SessionInfo.h> 00028 #include <activemq/commands/ProducerInfo.h> 00029 #include <activemq/commands/ConsumerInfo.h> 00030 #include <activemq/commands/ConnectionId.h> 00031 #include <activemq/commands/SessionId.h> 00032 #include <activemq/commands/ProducerId.h> 00033 #include <activemq/commands/ConsumerId.h> 00034 #include <activemq/commands/DestinationInfo.h> 00035 #include <activemq/commands/RemoveSubscriptionInfo.h> 00036 #include <activemq/commands/Message.h> 00037 #include <activemq/commands/MessageAck.h> 00038 #include <activemq/commands/MessagePull.h> 00039 #include <activemq/commands/TransactionInfo.h> 00040 #include <activemq/commands/WireFormatInfo.h> 00041 #include <activemq/commands/ProducerAck.h> 00042 #include <activemq/commands/MessageDispatch.h> 00043 #include <activemq/commands/MessageDispatchNotification.h> 00044 #include <activemq/commands/ControlCommand.h> 00045 #include <activemq/commands/ConnectionInfo.h> 00046 #include <activemq/commands/ConnectionError.h> 00047 #include <activemq/commands/ConnectionControl.h> 00048 #include <activemq/commands/ConsumerControl.h> 00049 #include <activemq/commands/ShutdownInfo.h> 00050 #include <activemq/commands/KeepAliveInfo.h> 00051 #include <activemq/commands/FlushCommand.h> 00052 #include <activemq/commands/BrokerError.h> 00053 #include <activemq/commands/BrokerInfo.h> 00054 #include <activemq/commands/RemoveInfo.h> 00055 #include <activemq/commands/ReplayCommand.h> 00056 #include <activemq/commands/Response.h> 00057 00058 namespace activemq { 00059 namespace state { 00060 00066 class AMQCPP_API CommandVisitorAdapter : public CommandVisitor { 00067 public: 00068 00069 virtual ~CommandVisitorAdapter(); 00070 00071 virtual decaf::lang::Pointer<commands::Command> processRemoveConnection(commands::ConnectionId* id AMQCPP_UNUSED) { 00072 return decaf::lang::Pointer<commands::Command>(); 00073 } 00074 00075 virtual decaf::lang::Pointer<commands::Command> processRemoveSession(commands::SessionId* id AMQCPP_UNUSED) { 00076 return decaf::lang::Pointer<commands::Command>(); 00077 } 00078 00079 virtual decaf::lang::Pointer<commands::Command> processRemoveProducer(commands::ProducerId* id AMQCPP_UNUSED) { 00080 return decaf::lang::Pointer<commands::Command>(); 00081 } 00082 00083 virtual decaf::lang::Pointer<commands::Command> processRemoveConsumer(commands::ConsumerId* id AMQCPP_UNUSED) { 00084 return decaf::lang::Pointer<commands::Command>(); 00085 } 00086 00087 virtual decaf::lang::Pointer<commands::Command> processDestinationInfo(commands::DestinationInfo* info AMQCPP_UNUSED) { 00088 return decaf::lang::Pointer<commands::Command>(); 00089 } 00090 00091 virtual decaf::lang::Pointer<commands::Command> processRemoveDestination(commands::DestinationInfo* info AMQCPP_UNUSED) { 00092 return decaf::lang::Pointer<commands::Command>(); 00093 } 00094 00095 virtual decaf::lang::Pointer<commands::Command> processRemoveSubscriptionInfo(commands::RemoveSubscriptionInfo* info AMQCPP_UNUSED) { 00096 return decaf::lang::Pointer<commands::Command>(); 00097 } 00098 00099 virtual decaf::lang::Pointer<commands::Command> processMessage(commands::Message* send AMQCPP_UNUSED) { 00100 return decaf::lang::Pointer<commands::Command>(); 00101 } 00102 00103 virtual decaf::lang::Pointer<commands::Command> processMessageAck(commands::MessageAck* ack AMQCPP_UNUSED) { 00104 return decaf::lang::Pointer<commands::Command>(); 00105 } 00106 00107 virtual decaf::lang::Pointer<commands::Command> processMessagePull(commands::MessagePull* pull AMQCPP_UNUSED) { 00108 return decaf::lang::Pointer<commands::Command>(); 00109 } 00110 00111 virtual decaf::lang::Pointer<commands::Command> processBeginTransaction(commands::TransactionInfo* info AMQCPP_UNUSED) { 00112 return decaf::lang::Pointer<commands::Command>(); 00113 } 00114 00115 virtual decaf::lang::Pointer<commands::Command> processPrepareTransaction(commands::TransactionInfo* info AMQCPP_UNUSED) { 00116 return decaf::lang::Pointer<commands::Command>(); 00117 } 00118 00119 virtual decaf::lang::Pointer<commands::Command> processCommitTransactionOnePhase(commands::TransactionInfo* info AMQCPP_UNUSED) { 00120 return decaf::lang::Pointer<commands::Command>(); 00121 } 00122 00123 virtual decaf::lang::Pointer<commands::Command> processCommitTransactionTwoPhase(commands::TransactionInfo* info AMQCPP_UNUSED) { 00124 return decaf::lang::Pointer<commands::Command>(); 00125 } 00126 00127 virtual decaf::lang::Pointer<commands::Command> processRollbackTransaction(commands::TransactionInfo* info AMQCPP_UNUSED) { 00128 return decaf::lang::Pointer<commands::Command>(); 00129 } 00130 00131 virtual decaf::lang::Pointer<commands::Command> processWireFormat(commands::WireFormatInfo* info AMQCPP_UNUSED) { 00132 return decaf::lang::Pointer<commands::Command>(); 00133 } 00134 00135 virtual decaf::lang::Pointer<commands::Command> processKeepAliveInfo(commands::KeepAliveInfo* info AMQCPP_UNUSED) { 00136 return decaf::lang::Pointer<commands::Command>(); 00137 } 00138 00139 virtual decaf::lang::Pointer<commands::Command> processShutdownInfo(commands::ShutdownInfo* info AMQCPP_UNUSED) { 00140 return decaf::lang::Pointer<commands::Command>(); 00141 } 00142 00143 virtual decaf::lang::Pointer<commands::Command> processFlushCommand(commands::FlushCommand* command AMQCPP_UNUSED) { 00144 return decaf::lang::Pointer<commands::Command>(); 00145 } 00146 00147 virtual decaf::lang::Pointer<commands::Command> processBrokerInfo(commands::BrokerInfo* info AMQCPP_UNUSED) { 00148 return decaf::lang::Pointer<commands::Command>(); 00149 } 00150 00151 virtual decaf::lang::Pointer<commands::Command> processRecoverTransactions(commands::TransactionInfo* info AMQCPP_UNUSED) { 00152 return decaf::lang::Pointer<commands::Command>(); 00153 } 00154 00155 virtual decaf::lang::Pointer<commands::Command> processForgetTransaction(commands::TransactionInfo* info AMQCPP_UNUSED) { 00156 return decaf::lang::Pointer<commands::Command>(); 00157 } 00158 00159 virtual decaf::lang::Pointer<commands::Command> processEndTransaction(commands::TransactionInfo* info AMQCPP_UNUSED) { 00160 return decaf::lang::Pointer<commands::Command>(); 00161 } 00162 00163 virtual decaf::lang::Pointer<commands::Command> processMessageDispatchNotification(commands::MessageDispatchNotification* notification AMQCPP_UNUSED) { 00164 return decaf::lang::Pointer<commands::Command>(); 00165 } 00166 00167 virtual decaf::lang::Pointer<commands::Command> processProducerAck(commands::ProducerAck* ack AMQCPP_UNUSED) { 00168 return decaf::lang::Pointer<commands::Command>(); 00169 } 00170 00171 virtual decaf::lang::Pointer<commands::Command> processMessageDispatch(commands::MessageDispatch* dispatch AMQCPP_UNUSED) { 00172 return decaf::lang::Pointer<commands::Command>(); 00173 } 00174 00175 virtual decaf::lang::Pointer<commands::Command> processControlCommand(commands::ControlCommand* command AMQCPP_UNUSED) { 00176 return decaf::lang::Pointer<commands::Command>(); 00177 } 00178 00179 virtual decaf::lang::Pointer<commands::Command> processConnectionError(commands::ConnectionError* error AMQCPP_UNUSED) { 00180 return decaf::lang::Pointer<commands::Command>(); 00181 } 00182 00183 virtual decaf::lang::Pointer<commands::Command> processConnectionControl(commands::ConnectionControl* control AMQCPP_UNUSED) { 00184 return decaf::lang::Pointer<commands::Command>(); 00185 } 00186 00187 virtual decaf::lang::Pointer<commands::Command> processConsumerControl(commands::ConsumerControl* control AMQCPP_UNUSED) { 00188 return decaf::lang::Pointer<commands::Command>(); 00189 } 00190 00191 virtual decaf::lang::Pointer<commands::Command> processBrokerError(commands::BrokerError* error AMQCPP_UNUSED) { 00192 return decaf::lang::Pointer<commands::Command>(); 00193 } 00194 00195 virtual decaf::lang::Pointer<commands::Command> processReplayCommand(commands::ReplayCommand* replay AMQCPP_UNUSED) { 00196 return decaf::lang::Pointer<commands::Command>(); 00197 } 00198 00199 virtual decaf::lang::Pointer<commands::Command> processResponse(commands::Response* response AMQCPP_UNUSED) { 00200 return decaf::lang::Pointer<commands::Command>(); 00201 } 00202 00203 virtual decaf::lang::Pointer<commands::Command> processConnectionInfo(commands::ConnectionInfo* info AMQCPP_UNUSED) { 00204 return decaf::lang::Pointer<commands::Command>(); 00205 } 00206 00207 virtual decaf::lang::Pointer<commands::Command> processSessionInfo(commands::SessionInfo* info AMQCPP_UNUSED) { 00208 return decaf::lang::Pointer<commands::Command>(); 00209 } 00210 00211 virtual decaf::lang::Pointer<commands::Command> processProducerInfo(commands::ProducerInfo* info AMQCPP_UNUSED) { 00212 return decaf::lang::Pointer<commands::Command>(); 00213 } 00214 00215 virtual decaf::lang::Pointer<commands::Command> processConsumerInfo(commands::ConsumerInfo* info AMQCPP_UNUSED) { 00216 return decaf::lang::Pointer<commands::Command>(); 00217 } 00218 00219 virtual decaf::lang::Pointer<commands::Command> processTransactionInfo(commands::TransactionInfo* info); 00220 00221 virtual decaf::lang::Pointer<commands::Command> processRemoveInfo(commands::RemoveInfo* info); 00222 00223 }; 00224 00225 }} 00226 00227 #endif /*_ACTIVEMQ_STATE_COMMANDVISITORADAPTER_H_*/
1.6.1