Apache Qpid C++ API
Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation

gen/qpid/framing/AllInvoker.h

Go to the documentation of this file.
00001 #ifndef QPID_FRAMING_ALLINVOKER_H
00002 #define QPID_FRAMING_ALLINVOKER_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_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 ClusterUpdateRequestBody& body);
00123     void visit(const ClusterUpdateOfferBody& body);
00124     void visit(const ClusterRetractOfferBody& body);
00125     void visit(const ClusterReadyBody& body);
00126     void visit(const ClusterConfigChangeBody& body);
00127     void visit(const ClusterMessageExpiredBody& body);
00128     void visit(const ClusterErrorCheckBody& body);
00129     void visit(const ClusterShutdownBody& body);
00130     void visit(const ClusterConnectionAnnounceBody& body);
00131     void visit(const ClusterConnectionDeliverCloseBody& body);
00132     void visit(const ClusterConnectionDeliverDoOutputBody& body);
00133     void visit(const ClusterConnectionAbortBody& body);
00134     void visit(const ClusterConnectionConsumerStateBody& body);
00135     void visit(const ClusterConnectionDeliveryRecordBody& body);
00136     void visit(const ClusterConnectionTxStartBody& body);
00137     void visit(const ClusterConnectionTxAcceptBody& body);
00138     void visit(const ClusterConnectionTxDequeueBody& body);
00139     void visit(const ClusterConnectionTxEnqueueBody& body);
00140     void visit(const ClusterConnectionTxPublishBody& body);
00141     void visit(const ClusterConnectionTxEndBody& body);
00142     void visit(const ClusterConnectionAccumulatedAckBody& body);
00143     void visit(const ClusterConnectionSessionStateBody& body);
00144     void visit(const ClusterConnectionShadowReadyBody& body);
00145     void visit(const ClusterConnectionMembershipBody& body);
00146     void visit(const ClusterConnectionRetractOfferBody& body);
00147     void visit(const ClusterConnectionQueuePositionBody& body);
00148     void visit(const ClusterConnectionExchangeBody& body);
00149     void visit(const ClusterConnectionQueueBody& body);
00150     void visit(const ClusterConnectionExpiryIdBody& body);
00151     void visit(const ClusterConnectionAddQueueListenerBody& body);
00152 };
00153 
00154 class AMQP_AllOperations::ConnectionHandler::Invoker:
00155     public qpid::framing::Invoker
00156 {
00157     AMQP_AllOperations::ConnectionHandler& target;
00158   public:
00159     Invoker(AMQP_AllOperations::ConnectionHandler& target_) : target(target_) {}
00160     using MethodBodyDefaultVisitor::visit;
00161     void visit(const ConnectionStartBody& body);
00162     void visit(const ConnectionStartOkBody& body);
00163     void visit(const ConnectionSecureBody& body);
00164     void visit(const ConnectionSecureOkBody& body);
00165     void visit(const ConnectionTuneBody& body);
00166     void visit(const ConnectionTuneOkBody& body);
00167     void visit(const ConnectionOpenBody& body);
00168     void visit(const ConnectionOpenOkBody& body);
00169     void visit(const ConnectionRedirectBody& body);
00170     void visit(const ConnectionHeartbeatBody& body);
00171     void visit(const ConnectionCloseBody& body);
00172     void visit(const ConnectionCloseOkBody& body);
00173 };
00174 
00175 class AMQP_AllOperations::SessionHandler::Invoker:
00176     public qpid::framing::Invoker
00177 {
00178     AMQP_AllOperations::SessionHandler& target;
00179   public:
00180     Invoker(AMQP_AllOperations::SessionHandler& target_) : target(target_) {}
00181     using MethodBodyDefaultVisitor::visit;
00182     void visit(const SessionAttachBody& body);
00183     void visit(const SessionAttachedBody& body);
00184     void visit(const SessionDetachBody& body);
00185     void visit(const SessionDetachedBody& body);
00186     void visit(const SessionRequestTimeoutBody& body);
00187     void visit(const SessionTimeoutBody& body);
00188     void visit(const SessionCommandPointBody& body);
00189     void visit(const SessionExpectedBody& body);
00190     void visit(const SessionConfirmedBody& body);
00191     void visit(const SessionCompletedBody& body);
00192     void visit(const SessionKnownCompletedBody& body);
00193     void visit(const SessionFlushBody& body);
00194     void visit(const SessionGapBody& body);
00195 };
00196 
00197 class AMQP_AllOperations::ExecutionHandler::Invoker:
00198     public qpid::framing::Invoker
00199 {
00200     AMQP_AllOperations::ExecutionHandler& target;
00201   public:
00202     Invoker(AMQP_AllOperations::ExecutionHandler& target_) : target(target_) {}
00203     using MethodBodyDefaultVisitor::visit;
00204     void visit(const ExecutionSyncBody& body);
00205     void visit(const ExecutionResultBody& body);
00206     void visit(const ExecutionExceptionBody& body);
00207 };
00208 
00209 class AMQP_AllOperations::MessageHandler::Invoker:
00210     public qpid::framing::Invoker
00211 {
00212     AMQP_AllOperations::MessageHandler& target;
00213   public:
00214     Invoker(AMQP_AllOperations::MessageHandler& target_) : target(target_) {}
00215     using MethodBodyDefaultVisitor::visit;
00216     void visit(const MessageAcceptBody& body);
00217     void visit(const MessageRejectBody& body);
00218     void visit(const MessageReleaseBody& body);
00219     void visit(const MessageAcquireBody& body);
00220     void visit(const MessageResumeBody& body);
00221     void visit(const MessageSubscribeBody& body);
00222     void visit(const MessageCancelBody& body);
00223     void visit(const MessageSetFlowModeBody& body);
00224     void visit(const MessageFlowBody& body);
00225     void visit(const MessageFlushBody& body);
00226     void visit(const MessageStopBody& body);
00227 };
00228 
00229 class AMQP_AllOperations::TxHandler::Invoker:
00230     public qpid::framing::Invoker
00231 {
00232     AMQP_AllOperations::TxHandler& target;
00233   public:
00234     Invoker(AMQP_AllOperations::TxHandler& target_) : target(target_) {}
00235     using MethodBodyDefaultVisitor::visit;
00236     void visit(const TxSelectBody& body);
00237     void visit(const TxCommitBody& body);
00238     void visit(const TxRollbackBody& body);
00239 };
00240 
00241 class AMQP_AllOperations::DtxHandler::Invoker:
00242     public qpid::framing::Invoker
00243 {
00244     AMQP_AllOperations::DtxHandler& target;
00245   public:
00246     Invoker(AMQP_AllOperations::DtxHandler& target_) : target(target_) {}
00247     using MethodBodyDefaultVisitor::visit;
00248     void visit(const DtxSelectBody& body);
00249     void visit(const DtxStartBody& body);
00250     void visit(const DtxEndBody& body);
00251     void visit(const DtxCommitBody& body);
00252     void visit(const DtxForgetBody& body);
00253     void visit(const DtxGetTimeoutBody& body);
00254     void visit(const DtxPrepareBody& body);
00255     void visit(const DtxRecoverBody& body);
00256     void visit(const DtxRollbackBody& body);
00257     void visit(const DtxSetTimeoutBody& body);
00258 };
00259 
00260 class AMQP_AllOperations::ExchangeHandler::Invoker:
00261     public qpid::framing::Invoker
00262 {
00263     AMQP_AllOperations::ExchangeHandler& target;
00264   public:
00265     Invoker(AMQP_AllOperations::ExchangeHandler& target_) : target(target_) {}
00266     using MethodBodyDefaultVisitor::visit;
00267     void visit(const ExchangeDeclareBody& body);
00268     void visit(const ExchangeDeleteBody& body);
00269     void visit(const ExchangeQueryBody& body);
00270     void visit(const ExchangeBindBody& body);
00271     void visit(const ExchangeUnbindBody& body);
00272     void visit(const ExchangeBoundBody& body);
00273 };
00274 
00275 class AMQP_AllOperations::QueueHandler::Invoker:
00276     public qpid::framing::Invoker
00277 {
00278     AMQP_AllOperations::QueueHandler& target;
00279   public:
00280     Invoker(AMQP_AllOperations::QueueHandler& target_) : target(target_) {}
00281     using MethodBodyDefaultVisitor::visit;
00282     void visit(const QueueDeclareBody& body);
00283     void visit(const QueueDeleteBody& body);
00284     void visit(const QueuePurgeBody& body);
00285     void visit(const QueueQueryBody& body);
00286 };
00287 
00288 class AMQP_AllOperations::FileHandler::Invoker:
00289     public qpid::framing::Invoker
00290 {
00291     AMQP_AllOperations::FileHandler& target;
00292   public:
00293     Invoker(AMQP_AllOperations::FileHandler& target_) : target(target_) {}
00294     using MethodBodyDefaultVisitor::visit;
00295     void visit(const FileQosBody& body);
00296     void visit(const FileQosOkBody& body);
00297     void visit(const FileConsumeBody& body);
00298     void visit(const FileConsumeOkBody& body);
00299     void visit(const FileCancelBody& body);
00300     void visit(const FileOpenBody& body);
00301     void visit(const FileOpenOkBody& body);
00302     void visit(const FilePublishBody& body);
00303     void visit(const FileDeliverBody& body);
00304     void visit(const FileAckBody& body);
00305     void visit(const FileRejectBody& body);
00306 };
00307 
00308 class AMQP_AllOperations::StreamHandler::Invoker:
00309     public qpid::framing::Invoker
00310 {
00311     AMQP_AllOperations::StreamHandler& target;
00312   public:
00313     Invoker(AMQP_AllOperations::StreamHandler& target_) : target(target_) {}
00314     using MethodBodyDefaultVisitor::visit;
00315     void visit(const StreamQosBody& body);
00316     void visit(const StreamQosOkBody& body);
00317     void visit(const StreamConsumeBody& body);
00318     void visit(const StreamConsumeOkBody& body);
00319     void visit(const StreamCancelBody& body);
00320 };
00321 
00322 class AMQP_AllOperations::ClusterHandler::Invoker:
00323     public qpid::framing::Invoker
00324 {
00325     AMQP_AllOperations::ClusterHandler& target;
00326   public:
00327     Invoker(AMQP_AllOperations::ClusterHandler& target_) : target(target_) {}
00328     using MethodBodyDefaultVisitor::visit;
00329     void visit(const ClusterUpdateRequestBody& body);
00330     void visit(const ClusterUpdateOfferBody& body);
00331     void visit(const ClusterRetractOfferBody& body);
00332     void visit(const ClusterReadyBody& body);
00333     void visit(const ClusterConfigChangeBody& body);
00334     void visit(const ClusterMessageExpiredBody& body);
00335     void visit(const ClusterErrorCheckBody& body);
00336     void visit(const ClusterShutdownBody& body);
00337 };
00338 
00339 class AMQP_AllOperations::ClusterConnectionHandler::Invoker:
00340     public qpid::framing::Invoker
00341 {
00342     AMQP_AllOperations::ClusterConnectionHandler& target;
00343   public:
00344     Invoker(AMQP_AllOperations::ClusterConnectionHandler& target_) : target(target_) {}
00345     using MethodBodyDefaultVisitor::visit;
00346     void visit(const ClusterConnectionAnnounceBody& body);
00347     void visit(const ClusterConnectionDeliverCloseBody& body);
00348     void visit(const ClusterConnectionDeliverDoOutputBody& body);
00349     void visit(const ClusterConnectionAbortBody& body);
00350     void visit(const ClusterConnectionConsumerStateBody& body);
00351     void visit(const ClusterConnectionDeliveryRecordBody& body);
00352     void visit(const ClusterConnectionTxStartBody& body);
00353     void visit(const ClusterConnectionTxAcceptBody& body);
00354     void visit(const ClusterConnectionTxDequeueBody& body);
00355     void visit(const ClusterConnectionTxEnqueueBody& body);
00356     void visit(const ClusterConnectionTxPublishBody& body);
00357     void visit(const ClusterConnectionTxEndBody& body);
00358     void visit(const ClusterConnectionAccumulatedAckBody& body);
00359     void visit(const ClusterConnectionSessionStateBody& body);
00360     void visit(const ClusterConnectionShadowReadyBody& body);
00361     void visit(const ClusterConnectionMembershipBody& body);
00362     void visit(const ClusterConnectionRetractOfferBody& body);
00363     void visit(const ClusterConnectionQueuePositionBody& body);
00364     void visit(const ClusterConnectionExchangeBody& body);
00365     void visit(const ClusterConnectionQueueBody& body);
00366     void visit(const ClusterConnectionExpiryIdBody& body);
00367     void visit(const ClusterConnectionAddQueueListenerBody& body);
00368 };
00369 
00370 }} // namespace qpid::framing
00371 
00372 #endif  

Qpid C++ API Reference
Generated on Tue Dec 8 15:39:35 2009 for Qpid C++ Client API by doxygen 1.4.7