/usr/share/cruisecontrol-bin-2.6.1/projects/qpid-trunk/cpp/src/gen/qpid/framing/ServerInvoker.h

00001 #ifndef QPID_FRAMING_SERVERINVOKER_H
00002 #define QPID_FRAMING_SERVERINVOKER_H
00003 /*
00004  *
00005  * Licensed to the Apache Software Foundation (ASF) under one
00006  * or more contributor license agreements.  See the NOTICE file
00007  * distributed with this work for additional information
00008  * regarding copyright ownership.  The ASF licenses this file
00009  * to you under the Apache License, Version 2.0 (the
00010  * "License"); you may not use this file except in compliance
00011  * with the License.  You may obtain a copy of the License at
00012  *
00013  *   http://www.apache.org/licenses/LICENSE-2.0
00014  *
00015  * Unless required by applicable law or agreed to in writing,
00016  * software distributed under the License is distributed on an
00017  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
00018  * KIND, either express or implied.  See the License for the
00019  * specific language governing permissions and limitations
00020  * under the License.
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 }} // namespace qpid::framing
00523 
00524 #endif  

Generated on Thu Apr 10 11:08:17 2008 for Qpid by  doxygen 1.4.7