00001 #ifndef QPID_FRAMING_SERVERINVOKER_H
00002 #define QPID_FRAMING_SERVERINVOKER_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_ServerOperations.h"
00031 #include "qpid/framing/Invoker.h"
00032
00033 namespace qpid {
00034 namespace framing {
00035
00036
00037 class AMQP_ServerOperations::Invoker:
00038 public qpid::framing::Invoker
00039 {
00040 AMQP_ServerOperations& target;
00041 public:
00042 Invoker(AMQP_ServerOperations& target_) : target(target_) {}
00043 using MethodBodyDefaultVisitor::visit;
00044 void visit(const ConnectionStartOkBody& body);
00045 void visit(const ConnectionSecureOkBody& body);
00046 void visit(const ConnectionTuneOkBody& body);
00047 void visit(const ConnectionOpenBody& body);
00048 void visit(const ConnectionCloseBody& body);
00049 void visit(const ConnectionCloseOkBody& body);
00050 void visit(const SessionOpenBody& body);
00051 void visit(const SessionFlowBody& body);
00052 void visit(const SessionFlowOkBody& body);
00053 void visit(const SessionCloseBody& body);
00054 void visit(const SessionClosedBody& body);
00055 void visit(const SessionResumeBody& body);
00056 void visit(const SessionSuspendBody& body);
00057 void visit(const SessionAckBody& body);
00058 void visit(const SessionHighWaterMarkBody& body);
00059 void visit(const SessionSolicitAckBody& body);
00060 void visit(const AccessRequestBody& body);
00061 void visit(const ExchangeDeclareBody& body);
00062 void visit(const ExchangeDeleteBody& body);
00063 void visit(const ExchangeQueryBody& body);
00064 void visit(const QueueDeclareBody& body);
00065 void visit(const QueueBindBody& body);
00066 void visit(const QueueUnbindBody& body);
00067 void visit(const QueuePurgeBody& body);
00068 void visit(const QueueDeleteBody& body);
00069 void visit(const QueueQueryBody& body);
00070 void visit(const BasicQosBody& body);
00071 void visit(const BasicConsumeBody& body);
00072 void visit(const BasicCancelBody& body);
00073 void visit(const BasicGetBody& body);
00074 void visit(const BasicAckBody& body);
00075 void visit(const BasicRejectBody& body);
00076 void visit(const BasicRecoverBody& body);
00077 void visit(const FileQosBody& body);
00078 void visit(const FileConsumeBody& body);
00079 void visit(const FileCancelBody& body);
00080 void visit(const FileOpenBody& body);
00081 void visit(const FileOpenOkBody& body);
00082 void visit(const FilePublishBody& body);
00083 void visit(const FileAckBody& body);
00084 void visit(const FileRejectBody& body);
00085 void visit(const StreamQosBody& body);
00086 void visit(const StreamConsumeBody& body);
00087 void visit(const StreamCancelBody& body);
00088 void visit(const TxSelectBody& body);
00089 void visit(const TxCommitBody& body);
00090 void visit(const TxRollbackBody& body);
00091 void visit(const DtxDemarcationSelectBody& body);
00092 void visit(const DtxDemarcationStartBody& body);
00093 void visit(const DtxDemarcationEndBody& body);
00094 void visit(const DtxCoordinationCommitBody& body);
00095 void visit(const DtxCoordinationForgetBody& body);
00096 void visit(const DtxCoordinationGetTimeoutBody& body);
00097 void visit(const DtxCoordinationPrepareBody& body);
00098 void visit(const DtxCoordinationRecoverBody& body);
00099 void visit(const DtxCoordinationRollbackBody& body);
00100 void visit(const DtxCoordinationSetTimeoutBody& body);
00101 void visit(const MessageRejectBody& body);
00102 void visit(const MessageAcquireBody& body);
00103 void visit(const MessageReleaseBody& body);
00104 void visit(const MessageSubscribeBody& body);
00105 void visit(const MessageCancelBody& body);
00106 void visit(const MessageGetBody& body);
00107 void visit(const MessageRecoverBody& body);
00108 void visit(const MessageOpenBody& body);
00109 void visit(const MessageCloseBody& body);
00110 void visit(const MessageAppendBody& body);
00111 void visit(const MessageCheckpointBody& body);
00112 void visit(const MessageResumeBody& body);
00113 void visit(const MessageQosBody& body);
00114 void visit(const MessageFlowModeBody& body);
00115 void visit(const MessageFlowBody& body);
00116 void visit(const MessageFlushBody& body);
00117 void visit(const MessageStopBody& body);
00118 void visit(const MessageEmptyBody& body);
00119 void visit(const MessageOffsetBody& body);
00120 void visit(const BindingQueryBody& body);
00121 void visit(const ExecutionFlushBody& body);
00122 void visit(const ExecutionCompleteBody& body);
00123 void visit(const ExecutionNoopBody& body);
00124 void visit(const ExecutionResultBody& body);
00125 void visit(const ExecutionSyncBody& body);
00126 void visit(const Connection010StartOkBody& body);
00127 void visit(const Connection010SecureOkBody& body);
00128 void visit(const Connection010TuneOkBody& body);
00129 void visit(const Connection010OpenBody& body);
00130 void visit(const Connection010HeartbeatBody& body);
00131 void visit(const Connection010CloseBody& body);
00132 void visit(const Connection010CloseOkBody& body);
00133 void visit(const Session010AttachBody& body);
00134 void visit(const Session010AttachedBody& body);
00135 void visit(const Session010DetachBody& body);
00136 void visit(const Session010DetachedBody& body);
00137 void visit(const Session010RequestTimeoutBody& body);
00138 void visit(const Session010TimeoutBody& body);
00139 void visit(const Session010CommandPointBody& body);
00140 void visit(const Session010ExpectedBody& body);
00141 void visit(const Session010ConfirmedBody& body);
00142 void visit(const Session010CompletedBody& body);
00143 void visit(const Session010KnownCompletedBody& body);
00144 void visit(const Session010FlushBody& body);
00145 void visit(const Session010GapBody& body);
00146 void visit(const Execution010SyncBody& body);
00147 void visit(const Execution010ResultBody& body);
00148 void visit(const Execution010ExceptionBody& body);
00149 void visit(const Message010TransferBody& body);
00150 void visit(const Message010AcceptBody& body);
00151 void visit(const Message010RejectBody& body);
00152 void visit(const Message010ReleaseBody& body);
00153 void visit(const Message010AcquireBody& body);
00154 void visit(const Message010SubscribeBody& body);
00155 void visit(const Message010CancelBody& body);
00156 void visit(const Message010SetFlowModeBody& body);
00157 void visit(const Message010FlowBody& body);
00158 void visit(const Message010FlushBody& body);
00159 void visit(const Message010StopBody& body);
00160 void visit(const Tx010SelectBody& body);
00161 void visit(const Tx010CommitBody& body);
00162 void visit(const Tx010RollbackBody& body);
00163 void visit(const Dtx010SelectBody& body);
00164 void visit(const Dtx010StartBody& body);
00165 void visit(const Dtx010EndBody& body);
00166 void visit(const Dtx010CommitBody& body);
00167 void visit(const Dtx010ForgetBody& body);
00168 void visit(const Dtx010GetTimeoutBody& body);
00169 void visit(const Dtx010PrepareBody& body);
00170 void visit(const Dtx010RecoverBody& body);
00171 void visit(const Dtx010RollbackBody& body);
00172 void visit(const Dtx010SetTimeoutBody& body);
00173 void visit(const Exchange010DeclareBody& body);
00174 void visit(const Exchange010DeleteBody& body);
00175 void visit(const Exchange010QueryBody& body);
00176 void visit(const Exchange010BindBody& body);
00177 void visit(const Exchange010UnbindBody& body);
00178 void visit(const Exchange010BoundBody& body);
00179 void visit(const Queue010DeclareBody& body);
00180 void visit(const Queue010DeleteBody& body);
00181 void visit(const Queue010PurgeBody& body);
00182 void visit(const Queue010QueryBody& body);
00183 };
00184
00185 class AMQP_ServerOperations::ConnectionHandler::Invoker:
00186 public qpid::framing::Invoker
00187 {
00188 AMQP_ServerOperations::ConnectionHandler& target;
00189 public:
00190 Invoker(AMQP_ServerOperations::ConnectionHandler& target_) : target(target_) {}
00191 using MethodBodyDefaultVisitor::visit;
00192 void visit(const ConnectionStartOkBody& body);
00193 void visit(const ConnectionSecureOkBody& body);
00194 void visit(const ConnectionTuneOkBody& body);
00195 void visit(const ConnectionOpenBody& body);
00196 void visit(const ConnectionCloseBody& body);
00197 void visit(const ConnectionCloseOkBody& body);
00198 };
00199
00200 class AMQP_ServerOperations::SessionHandler::Invoker:
00201 public qpid::framing::Invoker
00202 {
00203 AMQP_ServerOperations::SessionHandler& target;
00204 public:
00205 Invoker(AMQP_ServerOperations::SessionHandler& target_) : target(target_) {}
00206 using MethodBodyDefaultVisitor::visit;
00207 void visit(const SessionOpenBody& body);
00208 void visit(const SessionFlowBody& body);
00209 void visit(const SessionFlowOkBody& body);
00210 void visit(const SessionCloseBody& body);
00211 void visit(const SessionClosedBody& body);
00212 void visit(const SessionResumeBody& body);
00213 void visit(const SessionSuspendBody& body);
00214 void visit(const SessionAckBody& body);
00215 void visit(const SessionHighWaterMarkBody& body);
00216 void visit(const SessionSolicitAckBody& body);
00217 };
00218
00219 class AMQP_ServerOperations::AccessHandler::Invoker:
00220 public qpid::framing::Invoker
00221 {
00222 AMQP_ServerOperations::AccessHandler& target;
00223 public:
00224 Invoker(AMQP_ServerOperations::AccessHandler& target_) : target(target_) {}
00225 using MethodBodyDefaultVisitor::visit;
00226 void visit(const AccessRequestBody& body);
00227 };
00228
00229 class AMQP_ServerOperations::ExchangeHandler::Invoker:
00230 public qpid::framing::Invoker
00231 {
00232 AMQP_ServerOperations::ExchangeHandler& target;
00233 public:
00234 Invoker(AMQP_ServerOperations::ExchangeHandler& target_) : target(target_) {}
00235 using MethodBodyDefaultVisitor::visit;
00236 void visit(const ExchangeDeclareBody& body);
00237 void visit(const ExchangeDeleteBody& body);
00238 void visit(const ExchangeQueryBody& body);
00239 };
00240
00241 class AMQP_ServerOperations::QueueHandler::Invoker:
00242 public qpid::framing::Invoker
00243 {
00244 AMQP_ServerOperations::QueueHandler& target;
00245 public:
00246 Invoker(AMQP_ServerOperations::QueueHandler& target_) : target(target_) {}
00247 using MethodBodyDefaultVisitor::visit;
00248 void visit(const QueueDeclareBody& body);
00249 void visit(const QueueBindBody& body);
00250 void visit(const QueueUnbindBody& body);
00251 void visit(const QueuePurgeBody& body);
00252 void visit(const QueueDeleteBody& body);
00253 void visit(const QueueQueryBody& body);
00254 };
00255
00256 class AMQP_ServerOperations::BasicHandler::Invoker:
00257 public qpid::framing::Invoker
00258 {
00259 AMQP_ServerOperations::BasicHandler& target;
00260 public:
00261 Invoker(AMQP_ServerOperations::BasicHandler& target_) : target(target_) {}
00262 using MethodBodyDefaultVisitor::visit;
00263 void visit(const BasicQosBody& body);
00264 void visit(const BasicConsumeBody& body);
00265 void visit(const BasicCancelBody& body);
00266 void visit(const BasicGetBody& body);
00267 void visit(const BasicAckBody& body);
00268 void visit(const BasicRejectBody& body);
00269 void visit(const BasicRecoverBody& body);
00270 };
00271
00272 class AMQP_ServerOperations::FileHandler::Invoker:
00273 public qpid::framing::Invoker
00274 {
00275 AMQP_ServerOperations::FileHandler& target;
00276 public:
00277 Invoker(AMQP_ServerOperations::FileHandler& target_) : target(target_) {}
00278 using MethodBodyDefaultVisitor::visit;
00279 void visit(const FileQosBody& body);
00280 void visit(const FileConsumeBody& body);
00281 void visit(const FileCancelBody& body);
00282 void visit(const FileOpenBody& body);
00283 void visit(const FileOpenOkBody& body);
00284 void visit(const FilePublishBody& body);
00285 void visit(const FileAckBody& body);
00286 void visit(const FileRejectBody& body);
00287 };
00288
00289 class AMQP_ServerOperations::StreamHandler::Invoker:
00290 public qpid::framing::Invoker
00291 {
00292 AMQP_ServerOperations::StreamHandler& target;
00293 public:
00294 Invoker(AMQP_ServerOperations::StreamHandler& target_) : target(target_) {}
00295 using MethodBodyDefaultVisitor::visit;
00296 void visit(const StreamQosBody& body);
00297 void visit(const StreamConsumeBody& body);
00298 void visit(const StreamCancelBody& body);
00299 };
00300
00301 class AMQP_ServerOperations::TxHandler::Invoker:
00302 public qpid::framing::Invoker
00303 {
00304 AMQP_ServerOperations::TxHandler& target;
00305 public:
00306 Invoker(AMQP_ServerOperations::TxHandler& target_) : target(target_) {}
00307 using MethodBodyDefaultVisitor::visit;
00308 void visit(const TxSelectBody& body);
00309 void visit(const TxCommitBody& body);
00310 void visit(const TxRollbackBody& body);
00311 };
00312
00313 class AMQP_ServerOperations::DtxDemarcationHandler::Invoker:
00314 public qpid::framing::Invoker
00315 {
00316 AMQP_ServerOperations::DtxDemarcationHandler& target;
00317 public:
00318 Invoker(AMQP_ServerOperations::DtxDemarcationHandler& target_) : target(target_) {}
00319 using MethodBodyDefaultVisitor::visit;
00320 void visit(const DtxDemarcationSelectBody& body);
00321 void visit(const DtxDemarcationStartBody& body);
00322 void visit(const DtxDemarcationEndBody& body);
00323 };
00324
00325 class AMQP_ServerOperations::DtxCoordinationHandler::Invoker:
00326 public qpid::framing::Invoker
00327 {
00328 AMQP_ServerOperations::DtxCoordinationHandler& target;
00329 public:
00330 Invoker(AMQP_ServerOperations::DtxCoordinationHandler& target_) : target(target_) {}
00331 using MethodBodyDefaultVisitor::visit;
00332 void visit(const DtxCoordinationCommitBody& body);
00333 void visit(const DtxCoordinationForgetBody& body);
00334 void visit(const DtxCoordinationGetTimeoutBody& body);
00335 void visit(const DtxCoordinationPrepareBody& body);
00336 void visit(const DtxCoordinationRecoverBody& body);
00337 void visit(const DtxCoordinationRollbackBody& body);
00338 void visit(const DtxCoordinationSetTimeoutBody& body);
00339 };
00340
00341 class AMQP_ServerOperations::MessageHandler::Invoker:
00342 public qpid::framing::Invoker
00343 {
00344 AMQP_ServerOperations::MessageHandler& target;
00345 public:
00346 Invoker(AMQP_ServerOperations::MessageHandler& target_) : target(target_) {}
00347 using MethodBodyDefaultVisitor::visit;
00348 void visit(const MessageRejectBody& body);
00349 void visit(const MessageAcquireBody& body);
00350 void visit(const MessageReleaseBody& body);
00351 void visit(const MessageSubscribeBody& body);
00352 void visit(const MessageCancelBody& body);
00353 void visit(const MessageGetBody& body);
00354 void visit(const MessageRecoverBody& body);
00355 void visit(const MessageOpenBody& body);
00356 void visit(const MessageCloseBody& body);
00357 void visit(const MessageAppendBody& body);
00358 void visit(const MessageCheckpointBody& body);
00359 void visit(const MessageResumeBody& body);
00360 void visit(const MessageQosBody& body);
00361 void visit(const MessageFlowModeBody& body);
00362 void visit(const MessageFlowBody& body);
00363 void visit(const MessageFlushBody& body);
00364 void visit(const MessageStopBody& body);
00365 void visit(const MessageEmptyBody& body);
00366 void visit(const MessageOffsetBody& body);
00367 };
00368
00369 class AMQP_ServerOperations::BindingHandler::Invoker:
00370 public qpid::framing::Invoker
00371 {
00372 AMQP_ServerOperations::BindingHandler& target;
00373 public:
00374 Invoker(AMQP_ServerOperations::BindingHandler& target_) : target(target_) {}
00375 using MethodBodyDefaultVisitor::visit;
00376 void visit(const BindingQueryBody& body);
00377 };
00378
00379 class AMQP_ServerOperations::ExecutionHandler::Invoker:
00380 public qpid::framing::Invoker
00381 {
00382 AMQP_ServerOperations::ExecutionHandler& target;
00383 public:
00384 Invoker(AMQP_ServerOperations::ExecutionHandler& target_) : target(target_) {}
00385 using MethodBodyDefaultVisitor::visit;
00386 void visit(const ExecutionFlushBody& body);
00387 void visit(const ExecutionCompleteBody& body);
00388 void visit(const ExecutionNoopBody& body);
00389 void visit(const ExecutionResultBody& body);
00390 void visit(const ExecutionSyncBody& body);
00391 };
00392
00393 class AMQP_ServerOperations::Connection010Handler::Invoker:
00394 public qpid::framing::Invoker
00395 {
00396 AMQP_ServerOperations::Connection010Handler& target;
00397 public:
00398 Invoker(AMQP_ServerOperations::Connection010Handler& target_) : target(target_) {}
00399 using MethodBodyDefaultVisitor::visit;
00400 void visit(const Connection010StartOkBody& body);
00401 void visit(const Connection010SecureOkBody& body);
00402 void visit(const Connection010TuneOkBody& body);
00403 void visit(const Connection010OpenBody& body);
00404 void visit(const Connection010HeartbeatBody& body);
00405 void visit(const Connection010CloseBody& body);
00406 void visit(const Connection010CloseOkBody& body);
00407 };
00408
00409 class AMQP_ServerOperations::Session010Handler::Invoker:
00410 public qpid::framing::Invoker
00411 {
00412 AMQP_ServerOperations::Session010Handler& target;
00413 public:
00414 Invoker(AMQP_ServerOperations::Session010Handler& target_) : target(target_) {}
00415 using MethodBodyDefaultVisitor::visit;
00416 void visit(const Session010AttachBody& body);
00417 void visit(const Session010AttachedBody& body);
00418 void visit(const Session010DetachBody& body);
00419 void visit(const Session010DetachedBody& body);
00420 void visit(const Session010RequestTimeoutBody& body);
00421 void visit(const Session010TimeoutBody& body);
00422 void visit(const Session010CommandPointBody& body);
00423 void visit(const Session010ExpectedBody& body);
00424 void visit(const Session010ConfirmedBody& body);
00425 void visit(const Session010CompletedBody& body);
00426 void visit(const Session010KnownCompletedBody& body);
00427 void visit(const Session010FlushBody& body);
00428 void visit(const Session010GapBody& body);
00429 };
00430
00431 class AMQP_ServerOperations::Execution010Handler::Invoker:
00432 public qpid::framing::Invoker
00433 {
00434 AMQP_ServerOperations::Execution010Handler& target;
00435 public:
00436 Invoker(AMQP_ServerOperations::Execution010Handler& target_) : target(target_) {}
00437 using MethodBodyDefaultVisitor::visit;
00438 void visit(const Execution010SyncBody& body);
00439 void visit(const Execution010ResultBody& body);
00440 void visit(const Execution010ExceptionBody& body);
00441 };
00442
00443 class AMQP_ServerOperations::Message010Handler::Invoker:
00444 public qpid::framing::Invoker
00445 {
00446 AMQP_ServerOperations::Message010Handler& target;
00447 public:
00448 Invoker(AMQP_ServerOperations::Message010Handler& target_) : target(target_) {}
00449 using MethodBodyDefaultVisitor::visit;
00450 void visit(const Message010TransferBody& body);
00451 void visit(const Message010AcceptBody& body);
00452 void visit(const Message010RejectBody& body);
00453 void visit(const Message010ReleaseBody& body);
00454 void visit(const Message010AcquireBody& body);
00455 void visit(const Message010SubscribeBody& body);
00456 void visit(const Message010CancelBody& body);
00457 void visit(const Message010SetFlowModeBody& body);
00458 void visit(const Message010FlowBody& body);
00459 void visit(const Message010FlushBody& body);
00460 void visit(const Message010StopBody& body);
00461 };
00462
00463 class AMQP_ServerOperations::Tx010Handler::Invoker:
00464 public qpid::framing::Invoker
00465 {
00466 AMQP_ServerOperations::Tx010Handler& target;
00467 public:
00468 Invoker(AMQP_ServerOperations::Tx010Handler& target_) : target(target_) {}
00469 using MethodBodyDefaultVisitor::visit;
00470 void visit(const Tx010SelectBody& body);
00471 void visit(const Tx010CommitBody& body);
00472 void visit(const Tx010RollbackBody& body);
00473 };
00474
00475 class AMQP_ServerOperations::Dtx010Handler::Invoker:
00476 public qpid::framing::Invoker
00477 {
00478 AMQP_ServerOperations::Dtx010Handler& target;
00479 public:
00480 Invoker(AMQP_ServerOperations::Dtx010Handler& target_) : target(target_) {}
00481 using MethodBodyDefaultVisitor::visit;
00482 void visit(const Dtx010SelectBody& body);
00483 void visit(const Dtx010StartBody& body);
00484 void visit(const Dtx010EndBody& body);
00485 void visit(const Dtx010CommitBody& body);
00486 void visit(const Dtx010ForgetBody& body);
00487 void visit(const Dtx010GetTimeoutBody& body);
00488 void visit(const Dtx010PrepareBody& body);
00489 void visit(const Dtx010RecoverBody& body);
00490 void visit(const Dtx010RollbackBody& body);
00491 void visit(const Dtx010SetTimeoutBody& body);
00492 };
00493
00494 class AMQP_ServerOperations::Exchange010Handler::Invoker:
00495 public qpid::framing::Invoker
00496 {
00497 AMQP_ServerOperations::Exchange010Handler& target;
00498 public:
00499 Invoker(AMQP_ServerOperations::Exchange010Handler& target_) : target(target_) {}
00500 using MethodBodyDefaultVisitor::visit;
00501 void visit(const Exchange010DeclareBody& body);
00502 void visit(const Exchange010DeleteBody& body);
00503 void visit(const Exchange010QueryBody& body);
00504 void visit(const Exchange010BindBody& body);
00505 void visit(const Exchange010UnbindBody& body);
00506 void visit(const Exchange010BoundBody& body);
00507 };
00508
00509 class AMQP_ServerOperations::Queue010Handler::Invoker:
00510 public qpid::framing::Invoker
00511 {
00512 AMQP_ServerOperations::Queue010Handler& target;
00513 public:
00514 Invoker(AMQP_ServerOperations::Queue010Handler& target_) : target(target_) {}
00515 using MethodBodyDefaultVisitor::visit;
00516 void visit(const Queue010DeclareBody& body);
00517 void visit(const Queue010DeleteBody& body);
00518 void visit(const Queue010PurgeBody& body);
00519 void visit(const Queue010QueryBody& body);
00520 };
00521
00522 }}
00523
00524 #endif