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 };
00123
00124 class AMQP_AllOperations::ConnectionHandler::Invoker:
00125 public qpid::framing::Invoker
00126 {
00127 AMQP_AllOperations::ConnectionHandler& target;
00128 public:
00129 Invoker(AMQP_AllOperations::ConnectionHandler& target_) : target(target_) {}
00130 using MethodBodyDefaultVisitor::visit;
00131 void visit(const ConnectionStartBody& body);
00132 void visit(const ConnectionStartOkBody& body);
00133 void visit(const ConnectionSecureBody& body);
00134 void visit(const ConnectionSecureOkBody& body);
00135 void visit(const ConnectionTuneBody& body);
00136 void visit(const ConnectionTuneOkBody& body);
00137 void visit(const ConnectionOpenBody& body);
00138 void visit(const ConnectionOpenOkBody& body);
00139 void visit(const ConnectionRedirectBody& body);
00140 void visit(const ConnectionHeartbeatBody& body);
00141 void visit(const ConnectionCloseBody& body);
00142 void visit(const ConnectionCloseOkBody& body);
00143 };
00144
00145 class AMQP_AllOperations::SessionHandler::Invoker:
00146 public qpid::framing::Invoker
00147 {
00148 AMQP_AllOperations::SessionHandler& target;
00149 public:
00150 Invoker(AMQP_AllOperations::SessionHandler& target_) : target(target_) {}
00151 using MethodBodyDefaultVisitor::visit;
00152 void visit(const SessionAttachBody& body);
00153 void visit(const SessionAttachedBody& body);
00154 void visit(const SessionDetachBody& body);
00155 void visit(const SessionDetachedBody& body);
00156 void visit(const SessionRequestTimeoutBody& body);
00157 void visit(const SessionTimeoutBody& body);
00158 void visit(const SessionCommandPointBody& body);
00159 void visit(const SessionExpectedBody& body);
00160 void visit(const SessionConfirmedBody& body);
00161 void visit(const SessionCompletedBody& body);
00162 void visit(const SessionKnownCompletedBody& body);
00163 void visit(const SessionFlushBody& body);
00164 void visit(const SessionGapBody& body);
00165 };
00166
00167 class AMQP_AllOperations::ExecutionHandler::Invoker:
00168 public qpid::framing::Invoker
00169 {
00170 AMQP_AllOperations::ExecutionHandler& target;
00171 public:
00172 Invoker(AMQP_AllOperations::ExecutionHandler& target_) : target(target_) {}
00173 using MethodBodyDefaultVisitor::visit;
00174 void visit(const ExecutionSyncBody& body);
00175 void visit(const ExecutionResultBody& body);
00176 void visit(const ExecutionExceptionBody& body);
00177 };
00178
00179 class AMQP_AllOperations::MessageHandler::Invoker:
00180 public qpid::framing::Invoker
00181 {
00182 AMQP_AllOperations::MessageHandler& target;
00183 public:
00184 Invoker(AMQP_AllOperations::MessageHandler& target_) : target(target_) {}
00185 using MethodBodyDefaultVisitor::visit;
00186 void visit(const MessageAcceptBody& body);
00187 void visit(const MessageRejectBody& body);
00188 void visit(const MessageReleaseBody& body);
00189 void visit(const MessageAcquireBody& body);
00190 void visit(const MessageResumeBody& body);
00191 void visit(const MessageSubscribeBody& body);
00192 void visit(const MessageCancelBody& body);
00193 void visit(const MessageSetFlowModeBody& body);
00194 void visit(const MessageFlowBody& body);
00195 void visit(const MessageFlushBody& body);
00196 void visit(const MessageStopBody& body);
00197 };
00198
00199 class AMQP_AllOperations::TxHandler::Invoker:
00200 public qpid::framing::Invoker
00201 {
00202 AMQP_AllOperations::TxHandler& target;
00203 public:
00204 Invoker(AMQP_AllOperations::TxHandler& target_) : target(target_) {}
00205 using MethodBodyDefaultVisitor::visit;
00206 void visit(const TxSelectBody& body);
00207 void visit(const TxCommitBody& body);
00208 void visit(const TxRollbackBody& body);
00209 };
00210
00211 class AMQP_AllOperations::DtxHandler::Invoker:
00212 public qpid::framing::Invoker
00213 {
00214 AMQP_AllOperations::DtxHandler& target;
00215 public:
00216 Invoker(AMQP_AllOperations::DtxHandler& target_) : target(target_) {}
00217 using MethodBodyDefaultVisitor::visit;
00218 void visit(const DtxSelectBody& body);
00219 void visit(const DtxStartBody& body);
00220 void visit(const DtxEndBody& body);
00221 void visit(const DtxCommitBody& body);
00222 void visit(const DtxForgetBody& body);
00223 void visit(const DtxGetTimeoutBody& body);
00224 void visit(const DtxPrepareBody& body);
00225 void visit(const DtxRecoverBody& body);
00226 void visit(const DtxRollbackBody& body);
00227 void visit(const DtxSetTimeoutBody& body);
00228 };
00229
00230 class AMQP_AllOperations::ExchangeHandler::Invoker:
00231 public qpid::framing::Invoker
00232 {
00233 AMQP_AllOperations::ExchangeHandler& target;
00234 public:
00235 Invoker(AMQP_AllOperations::ExchangeHandler& target_) : target(target_) {}
00236 using MethodBodyDefaultVisitor::visit;
00237 void visit(const ExchangeDeclareBody& body);
00238 void visit(const ExchangeDeleteBody& body);
00239 void visit(const ExchangeQueryBody& body);
00240 void visit(const ExchangeBindBody& body);
00241 void visit(const ExchangeUnbindBody& body);
00242 void visit(const ExchangeBoundBody& body);
00243 };
00244
00245 class AMQP_AllOperations::QueueHandler::Invoker:
00246 public qpid::framing::Invoker
00247 {
00248 AMQP_AllOperations::QueueHandler& target;
00249 public:
00250 Invoker(AMQP_AllOperations::QueueHandler& target_) : target(target_) {}
00251 using MethodBodyDefaultVisitor::visit;
00252 void visit(const QueueDeclareBody& body);
00253 void visit(const QueueDeleteBody& body);
00254 void visit(const QueuePurgeBody& body);
00255 void visit(const QueueQueryBody& body);
00256 };
00257
00258 class AMQP_AllOperations::FileHandler::Invoker:
00259 public qpid::framing::Invoker
00260 {
00261 AMQP_AllOperations::FileHandler& target;
00262 public:
00263 Invoker(AMQP_AllOperations::FileHandler& target_) : target(target_) {}
00264 using MethodBodyDefaultVisitor::visit;
00265 void visit(const FileQosBody& body);
00266 void visit(const FileQosOkBody& body);
00267 void visit(const FileConsumeBody& body);
00268 void visit(const FileConsumeOkBody& body);
00269 void visit(const FileCancelBody& body);
00270 void visit(const FileOpenBody& body);
00271 void visit(const FileOpenOkBody& body);
00272 void visit(const FilePublishBody& body);
00273 void visit(const FileDeliverBody& body);
00274 void visit(const FileAckBody& body);
00275 void visit(const FileRejectBody& body);
00276 };
00277
00278 class AMQP_AllOperations::StreamHandler::Invoker:
00279 public qpid::framing::Invoker
00280 {
00281 AMQP_AllOperations::StreamHandler& target;
00282 public:
00283 Invoker(AMQP_AllOperations::StreamHandler& target_) : target(target_) {}
00284 using MethodBodyDefaultVisitor::visit;
00285 void visit(const StreamQosBody& body);
00286 void visit(const StreamQosOkBody& body);
00287 void visit(const StreamConsumeBody& body);
00288 void visit(const StreamConsumeOkBody& body);
00289 void visit(const StreamCancelBody& body);
00290 };
00291
00292 }}
00293
00294 #endif