00001 #ifndef QPID_FRAMING_ALLINVOKER_H
00002 #define QPID_FRAMING_ALLINVOKER_H
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00028
00029
00030 #include "qpid/framing/AMQP_AllOperations.h"
00031 #include "qpid/framing/Invoker.h"
00032
00033 namespace qpid {
00034 namespace framing {
00035
00036
00037 class AMQP_AllOperations::Invoker:
00038 public qpid::framing::Invoker
00039 {
00040 AMQP_AllOperations& target;
00041 public:
00042 Invoker(AMQP_AllOperations& target_) : target(target_) {}
00043 using MethodBodyDefaultVisitor::visit;
00044 void visit(const ConnectionStartBody& body);
00045 void visit(const ConnectionStartOkBody& body);
00046 void visit(const ConnectionSecureBody& body);
00047 void visit(const ConnectionSecureOkBody& body);
00048 void visit(const ConnectionTuneBody& body);
00049 void visit(const ConnectionTuneOkBody& body);
00050 void visit(const ConnectionOpenBody& body);
00051 void visit(const ConnectionOpenOkBody& body);
00052 void visit(const ConnectionRedirectBody& body);
00053 void visit(const ConnectionHeartbeatBody& body);
00054 void visit(const ConnectionCloseBody& body);
00055 void visit(const ConnectionCloseOkBody& body);
00056 void visit(const SessionAttachBody& body);
00057 void visit(const SessionAttachedBody& body);
00058 void visit(const SessionDetachBody& body);
00059 void visit(const SessionDetachedBody& body);
00060 void visit(const SessionRequestTimeoutBody& body);
00061 void visit(const SessionTimeoutBody& body);
00062 void visit(const SessionCommandPointBody& body);
00063 void visit(const SessionExpectedBody& body);
00064 void visit(const SessionConfirmedBody& body);
00065 void visit(const SessionCompletedBody& body);
00066 void visit(const SessionKnownCompletedBody& body);
00067 void visit(const SessionFlushBody& body);
00068 void visit(const SessionGapBody& body);
00069 void visit(const ExecutionSyncBody& body);
00070 void visit(const ExecutionResultBody& body);
00071 void visit(const ExecutionExceptionBody& body);
00072 void visit(const MessageAcceptBody& body);
00073 void visit(const MessageRejectBody& body);
00074 void visit(const MessageReleaseBody& body);
00075 void visit(const MessageAcquireBody& body);
00076 void visit(const MessageResumeBody& body);
00077 void visit(const MessageSubscribeBody& body);
00078 void visit(const MessageCancelBody& body);
00079 void visit(const MessageSetFlowModeBody& body);
00080 void visit(const MessageFlowBody& body);
00081 void visit(const MessageFlushBody& body);
00082 void visit(const MessageStopBody& body);
00083 void visit(const TxSelectBody& body);
00084 void visit(const TxCommitBody& body);
00085 void visit(const TxRollbackBody& body);
00086 void visit(const DtxSelectBody& body);
00087 void visit(const DtxStartBody& body);
00088 void visit(const DtxEndBody& body);
00089 void visit(const DtxCommitBody& body);
00090 void visit(const DtxForgetBody& body);
00091 void visit(const DtxGetTimeoutBody& body);
00092 void visit(const DtxPrepareBody& body);
00093 void visit(const DtxRecoverBody& body);
00094 void visit(const DtxRollbackBody& body);
00095 void visit(const DtxSetTimeoutBody& body);
00096 void visit(const ExchangeDeclareBody& body);
00097 void visit(const ExchangeDeleteBody& body);
00098 void visit(const ExchangeQueryBody& body);
00099 void visit(const ExchangeBindBody& body);
00100 void visit(const ExchangeUnbindBody& body);
00101 void visit(const ExchangeBoundBody& body);
00102 void visit(const QueueDeclareBody& body);
00103 void visit(const QueueDeleteBody& body);
00104 void visit(const QueuePurgeBody& body);
00105 void visit(const QueueQueryBody& body);
00106 void visit(const FileQosBody& body);
00107 void visit(const FileQosOkBody& body);
00108 void visit(const FileConsumeBody& body);
00109 void visit(const FileConsumeOkBody& body);
00110 void visit(const FileCancelBody& body);
00111 void visit(const FileOpenBody& body);
00112 void visit(const FileOpenOkBody& body);
00113 void visit(const FilePublishBody& body);
00114 void visit(const FileDeliverBody& body);
00115 void visit(const FileAckBody& body);
00116 void visit(const FileRejectBody& body);
00117 void visit(const StreamQosBody& body);
00118 void visit(const StreamQosOkBody& body);
00119 void visit(const StreamConsumeBody& body);
00120 void visit(const StreamConsumeOkBody& body);
00121 void visit(const StreamCancelBody& body);
00122 void visit(const ClusterDumpRequestBody& body);
00123 void visit(const ClusterDumpOfferBody& body);
00124 void visit(const ClusterDumpStartBody& body);
00125 void visit(const ClusterReadyBody& body);
00126 void visit(const ClusterConfigChangeBody& body);
00127 void visit(const ClusterShutdownBody& body);
00128 void visit(const ClusterConnectionDeliverCloseBody& body);
00129 void visit(const ClusterConnectionDeliverDoOutputBody& body);
00130 void visit(const ClusterConnectionSessionStateBody& body);
00131 void visit(const ClusterConnectionShadowReadyBody& body);
00132 void visit(const ClusterConnectionMembershipBody& body);
00133 };
00134
00135 class AMQP_AllOperations::ConnectionHandler::Invoker:
00136 public qpid::framing::Invoker
00137 {
00138 AMQP_AllOperations::ConnectionHandler& target;
00139 public:
00140 Invoker(AMQP_AllOperations::ConnectionHandler& target_) : target(target_) {}
00141 using MethodBodyDefaultVisitor::visit;
00142 void visit(const ConnectionStartBody& body);
00143 void visit(const ConnectionStartOkBody& body);
00144 void visit(const ConnectionSecureBody& body);
00145 void visit(const ConnectionSecureOkBody& body);
00146 void visit(const ConnectionTuneBody& body);
00147 void visit(const ConnectionTuneOkBody& body);
00148 void visit(const ConnectionOpenBody& body);
00149 void visit(const ConnectionOpenOkBody& body);
00150 void visit(const ConnectionRedirectBody& body);
00151 void visit(const ConnectionHeartbeatBody& body);
00152 void visit(const ConnectionCloseBody& body);
00153 void visit(const ConnectionCloseOkBody& body);
00154 };
00155
00156 class AMQP_AllOperations::SessionHandler::Invoker:
00157 public qpid::framing::Invoker
00158 {
00159 AMQP_AllOperations::SessionHandler& target;
00160 public:
00161 Invoker(AMQP_AllOperations::SessionHandler& target_) : target(target_) {}
00162 using MethodBodyDefaultVisitor::visit;
00163 void visit(const SessionAttachBody& body);
00164 void visit(const SessionAttachedBody& body);
00165 void visit(const SessionDetachBody& body);
00166 void visit(const SessionDetachedBody& body);
00167 void visit(const SessionRequestTimeoutBody& body);
00168 void visit(const SessionTimeoutBody& body);
00169 void visit(const SessionCommandPointBody& body);
00170 void visit(const SessionExpectedBody& body);
00171 void visit(const SessionConfirmedBody& body);
00172 void visit(const SessionCompletedBody& body);
00173 void visit(const SessionKnownCompletedBody& body);
00174 void visit(const SessionFlushBody& body);
00175 void visit(const SessionGapBody& body);
00176 };
00177
00178 class AMQP_AllOperations::ExecutionHandler::Invoker:
00179 public qpid::framing::Invoker
00180 {
00181 AMQP_AllOperations::ExecutionHandler& target;
00182 public:
00183 Invoker(AMQP_AllOperations::ExecutionHandler& target_) : target(target_) {}
00184 using MethodBodyDefaultVisitor::visit;
00185 void visit(const ExecutionSyncBody& body);
00186 void visit(const ExecutionResultBody& body);
00187 void visit(const ExecutionExceptionBody& body);
00188 };
00189
00190 class AMQP_AllOperations::MessageHandler::Invoker:
00191 public qpid::framing::Invoker
00192 {
00193 AMQP_AllOperations::MessageHandler& target;
00194 public:
00195 Invoker(AMQP_AllOperations::MessageHandler& target_) : target(target_) {}
00196 using MethodBodyDefaultVisitor::visit;
00197 void visit(const MessageAcceptBody& body);
00198 void visit(const MessageRejectBody& body);
00199 void visit(const MessageReleaseBody& body);
00200 void visit(const MessageAcquireBody& body);
00201 void visit(const MessageResumeBody& body);
00202 void visit(const MessageSubscribeBody& body);
00203 void visit(const MessageCancelBody& body);
00204 void visit(const MessageSetFlowModeBody& body);
00205 void visit(const MessageFlowBody& body);
00206 void visit(const MessageFlushBody& body);
00207 void visit(const MessageStopBody& body);
00208 };
00209
00210 class AMQP_AllOperations::TxHandler::Invoker:
00211 public qpid::framing::Invoker
00212 {
00213 AMQP_AllOperations::TxHandler& target;
00214 public:
00215 Invoker(AMQP_AllOperations::TxHandler& target_) : target(target_) {}
00216 using MethodBodyDefaultVisitor::visit;
00217 void visit(const TxSelectBody& body);
00218 void visit(const TxCommitBody& body);
00219 void visit(const TxRollbackBody& body);
00220 };
00221
00222 class AMQP_AllOperations::DtxHandler::Invoker:
00223 public qpid::framing::Invoker
00224 {
00225 AMQP_AllOperations::DtxHandler& target;
00226 public:
00227 Invoker(AMQP_AllOperations::DtxHandler& target_) : target(target_) {}
00228 using MethodBodyDefaultVisitor::visit;
00229 void visit(const DtxSelectBody& body);
00230 void visit(const DtxStartBody& body);
00231 void visit(const DtxEndBody& body);
00232 void visit(const DtxCommitBody& body);
00233 void visit(const DtxForgetBody& body);
00234 void visit(const DtxGetTimeoutBody& body);
00235 void visit(const DtxPrepareBody& body);
00236 void visit(const DtxRecoverBody& body);
00237 void visit(const DtxRollbackBody& body);
00238 void visit(const DtxSetTimeoutBody& body);
00239 };
00240
00241 class AMQP_AllOperations::ExchangeHandler::Invoker:
00242 public qpid::framing::Invoker
00243 {
00244 AMQP_AllOperations::ExchangeHandler& target;
00245 public:
00246 Invoker(AMQP_AllOperations::ExchangeHandler& target_) : target(target_) {}
00247 using MethodBodyDefaultVisitor::visit;
00248 void visit(const ExchangeDeclareBody& body);
00249 void visit(const ExchangeDeleteBody& body);
00250 void visit(const ExchangeQueryBody& body);
00251 void visit(const ExchangeBindBody& body);
00252 void visit(const ExchangeUnbindBody& body);
00253 void visit(const ExchangeBoundBody& body);
00254 };
00255
00256 class AMQP_AllOperations::QueueHandler::Invoker:
00257 public qpid::framing::Invoker
00258 {
00259 AMQP_AllOperations::QueueHandler& target;
00260 public:
00261 Invoker(AMQP_AllOperations::QueueHandler& target_) : target(target_) {}
00262 using MethodBodyDefaultVisitor::visit;
00263 void visit(const QueueDeclareBody& body);
00264 void visit(const QueueDeleteBody& body);
00265 void visit(const QueuePurgeBody& body);
00266 void visit(const QueueQueryBody& body);
00267 };
00268
00269 class AMQP_AllOperations::FileHandler::Invoker:
00270 public qpid::framing::Invoker
00271 {
00272 AMQP_AllOperations::FileHandler& target;
00273 public:
00274 Invoker(AMQP_AllOperations::FileHandler& target_) : target(target_) {}
00275 using MethodBodyDefaultVisitor::visit;
00276 void visit(const FileQosBody& body);
00277 void visit(const FileQosOkBody& body);
00278 void visit(const FileConsumeBody& body);
00279 void visit(const FileConsumeOkBody& body);
00280 void visit(const FileCancelBody& body);
00281 void visit(const FileOpenBody& body);
00282 void visit(const FileOpenOkBody& body);
00283 void visit(const FilePublishBody& body);
00284 void visit(const FileDeliverBody& body);
00285 void visit(const FileAckBody& body);
00286 void visit(const FileRejectBody& body);
00287 };
00288
00289 class AMQP_AllOperations::StreamHandler::Invoker:
00290 public qpid::framing::Invoker
00291 {
00292 AMQP_AllOperations::StreamHandler& target;
00293 public:
00294 Invoker(AMQP_AllOperations::StreamHandler& target_) : target(target_) {}
00295 using MethodBodyDefaultVisitor::visit;
00296 void visit(const StreamQosBody& body);
00297 void visit(const StreamQosOkBody& body);
00298 void visit(const StreamConsumeBody& body);
00299 void visit(const StreamConsumeOkBody& body);
00300 void visit(const StreamCancelBody& body);
00301 };
00302
00303 class AMQP_AllOperations::ClusterHandler::Invoker:
00304 public qpid::framing::Invoker
00305 {
00306 AMQP_AllOperations::ClusterHandler& target;
00307 public:
00308 Invoker(AMQP_AllOperations::ClusterHandler& target_) : target(target_) {}
00309 using MethodBodyDefaultVisitor::visit;
00310 void visit(const ClusterDumpRequestBody& body);
00311 void visit(const ClusterDumpOfferBody& body);
00312 void visit(const ClusterDumpStartBody& body);
00313 void visit(const ClusterReadyBody& body);
00314 void visit(const ClusterConfigChangeBody& body);
00315 void visit(const ClusterShutdownBody& body);
00316 };
00317
00318 class AMQP_AllOperations::ClusterConnectionHandler::Invoker:
00319 public qpid::framing::Invoker
00320 {
00321 AMQP_AllOperations::ClusterConnectionHandler& target;
00322 public:
00323 Invoker(AMQP_AllOperations::ClusterConnectionHandler& target_) : target(target_) {}
00324 using MethodBodyDefaultVisitor::visit;
00325 void visit(const ClusterConnectionDeliverCloseBody& body);
00326 void visit(const ClusterConnectionDeliverDoOutputBody& body);
00327 void visit(const ClusterConnectionSessionStateBody& body);
00328 void visit(const ClusterConnectionShadowReadyBody& body);
00329 void visit(const ClusterConnectionMembershipBody& body);
00330 };
00331
00332 }}
00333
00334 #endif