00001 #ifndef QPID_FRAMING_CLIENTINVOKER_H
00002 #define QPID_FRAMING_CLIENTINVOKER_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_ClientOperations.h"
00031 #include "qpid/framing/Invoker.h"
00032
00033 namespace qpid {
00034 namespace framing {
00035
00036
00037 class AMQP_ClientOperations::Invoker:
00038 public qpid::framing::Invoker
00039 {
00040 AMQP_ClientOperations& target;
00041 public:
00042 Invoker(AMQP_ClientOperations& target_) : target(target_) {}
00043 using MethodBodyDefaultVisitor::visit;
00044 void visit(const ConnectionStartBody& body);
00045 void visit(const ConnectionSecureBody& body);
00046 void visit(const ConnectionTuneBody& body);
00047 void visit(const ConnectionOpenOkBody& body);
00048 void visit(const ConnectionRedirectBody& body);
00049 void visit(const ConnectionCloseBody& body);
00050 void visit(const ConnectionCloseOkBody& body);
00051 void visit(const SessionAttachedBody& body);
00052 void visit(const SessionFlowBody& body);
00053 void visit(const SessionFlowOkBody& body);
00054 void visit(const SessionCloseBody& body);
00055 void visit(const SessionClosedBody& body);
00056 void visit(const SessionDetachedBody& body);
00057 void visit(const SessionAckBody& body);
00058 void visit(const SessionHighWaterMarkBody& body);
00059 void visit(const SessionSolicitAckBody& body);
00060 void visit(const AccessRequestOkBody& body);
00061 void visit(const BasicConsumeOkBody& body);
00062 void visit(const BasicGetEmptyBody& body);
00063 void visit(const FileQosOkBody& body);
00064 void visit(const FileConsumeOkBody& body);
00065 void visit(const FileOpenBody& body);
00066 void visit(const FileOpenOkBody& body);
00067 void visit(const FileDeliverBody& body);
00068 void visit(const StreamQosOkBody& body);
00069 void visit(const StreamConsumeOkBody& body);
00070 void visit(const MessageRejectBody& body);
00071 void visit(const MessageAcquiredBody& body);
00072 void visit(const MessageReleaseBody& body);
00073 void visit(const MessageOpenBody& body);
00074 void visit(const MessageCloseBody& body);
00075 void visit(const MessageAppendBody& body);
00076 void visit(const MessageCheckpointBody& body);
00077 void visit(const MessageResumeBody& body);
00078 void visit(const MessageFlowModeBody& body);
00079 void visit(const MessageFlowBody& body);
00080 void visit(const MessageStopBody& body);
00081 void visit(const MessageEmptyBody& body);
00082 void visit(const MessageOffsetBody& body);
00083 void visit(const ExecutionFlushBody& body);
00084 void visit(const ExecutionCompleteBody& body);
00085 void visit(const ExecutionNoopBody& body);
00086 void visit(const ExecutionResultBody& body);
00087 void visit(const ExecutionSyncBody& body);
00088 void visit(const Connection010StartBody& body);
00089 void visit(const Connection010SecureBody& body);
00090 void visit(const Connection010TuneBody& body);
00091 void visit(const Connection010OpenOkBody& body);
00092 void visit(const Connection010RedirectBody& body);
00093 void visit(const Connection010CloseBody& body);
00094 void visit(const Connection010CloseOkBody& body);
00095 void visit(const Session010AttachBody& body);
00096 void visit(const Session010AttachedBody& body);
00097 void visit(const Session010DetachBody& body);
00098 void visit(const Session010DetachedBody& body);
00099 void visit(const Session010RequestTimeoutBody& body);
00100 void visit(const Session010TimeoutBody& body);
00101 void visit(const Session010CommandPointBody& body);
00102 void visit(const Session010ExpectedBody& body);
00103 void visit(const Session010ConfirmedBody& body);
00104 void visit(const Session010CompletedBody& body);
00105 void visit(const Session010KnownCompletedBody& body);
00106 void visit(const Session010FlushBody& body);
00107 void visit(const Session010GapBody& body);
00108 void visit(const Execution010SyncBody& body);
00109 void visit(const Execution010ResultBody& body);
00110 void visit(const Execution010ExceptionBody& body);
00111 void visit(const Message010TransferBody& body);
00112 void visit(const Message010AcceptBody& body);
00113 void visit(const Message010RejectBody& body);
00114 };
00115
00116 class AMQP_ClientOperations::ConnectionHandler::Invoker:
00117 public qpid::framing::Invoker
00118 {
00119 AMQP_ClientOperations::ConnectionHandler& target;
00120 public:
00121 Invoker(AMQP_ClientOperations::ConnectionHandler& target_) : target(target_) {}
00122 using MethodBodyDefaultVisitor::visit;
00123 void visit(const ConnectionStartBody& body);
00124 void visit(const ConnectionSecureBody& body);
00125 void visit(const ConnectionTuneBody& body);
00126 void visit(const ConnectionOpenOkBody& body);
00127 void visit(const ConnectionRedirectBody& body);
00128 void visit(const ConnectionCloseBody& body);
00129 void visit(const ConnectionCloseOkBody& body);
00130 };
00131
00132 class AMQP_ClientOperations::SessionHandler::Invoker:
00133 public qpid::framing::Invoker
00134 {
00135 AMQP_ClientOperations::SessionHandler& target;
00136 public:
00137 Invoker(AMQP_ClientOperations::SessionHandler& target_) : target(target_) {}
00138 using MethodBodyDefaultVisitor::visit;
00139 void visit(const SessionAttachedBody& body);
00140 void visit(const SessionFlowBody& body);
00141 void visit(const SessionFlowOkBody& body);
00142 void visit(const SessionCloseBody& body);
00143 void visit(const SessionClosedBody& body);
00144 void visit(const SessionDetachedBody& body);
00145 void visit(const SessionAckBody& body);
00146 void visit(const SessionHighWaterMarkBody& body);
00147 void visit(const SessionSolicitAckBody& body);
00148 };
00149
00150 class AMQP_ClientOperations::AccessHandler::Invoker:
00151 public qpid::framing::Invoker
00152 {
00153 AMQP_ClientOperations::AccessHandler& target;
00154 public:
00155 Invoker(AMQP_ClientOperations::AccessHandler& target_) : target(target_) {}
00156 using MethodBodyDefaultVisitor::visit;
00157 void visit(const AccessRequestOkBody& body);
00158 };
00159
00160 class AMQP_ClientOperations::BasicHandler::Invoker:
00161 public qpid::framing::Invoker
00162 {
00163 AMQP_ClientOperations::BasicHandler& target;
00164 public:
00165 Invoker(AMQP_ClientOperations::BasicHandler& target_) : target(target_) {}
00166 using MethodBodyDefaultVisitor::visit;
00167 void visit(const BasicConsumeOkBody& body);
00168 void visit(const BasicGetEmptyBody& body);
00169 };
00170
00171 class AMQP_ClientOperations::FileHandler::Invoker:
00172 public qpid::framing::Invoker
00173 {
00174 AMQP_ClientOperations::FileHandler& target;
00175 public:
00176 Invoker(AMQP_ClientOperations::FileHandler& target_) : target(target_) {}
00177 using MethodBodyDefaultVisitor::visit;
00178 void visit(const FileQosOkBody& body);
00179 void visit(const FileConsumeOkBody& body);
00180 void visit(const FileOpenBody& body);
00181 void visit(const FileOpenOkBody& body);
00182 void visit(const FileDeliverBody& body);
00183 };
00184
00185 class AMQP_ClientOperations::StreamHandler::Invoker:
00186 public qpid::framing::Invoker
00187 {
00188 AMQP_ClientOperations::StreamHandler& target;
00189 public:
00190 Invoker(AMQP_ClientOperations::StreamHandler& target_) : target(target_) {}
00191 using MethodBodyDefaultVisitor::visit;
00192 void visit(const StreamQosOkBody& body);
00193 void visit(const StreamConsumeOkBody& body);
00194 };
00195
00196 class AMQP_ClientOperations::MessageHandler::Invoker:
00197 public qpid::framing::Invoker
00198 {
00199 AMQP_ClientOperations::MessageHandler& target;
00200 public:
00201 Invoker(AMQP_ClientOperations::MessageHandler& target_) : target(target_) {}
00202 using MethodBodyDefaultVisitor::visit;
00203 void visit(const MessageRejectBody& body);
00204 void visit(const MessageAcquiredBody& body);
00205 void visit(const MessageReleaseBody& body);
00206 void visit(const MessageOpenBody& body);
00207 void visit(const MessageCloseBody& body);
00208 void visit(const MessageAppendBody& body);
00209 void visit(const MessageCheckpointBody& body);
00210 void visit(const MessageResumeBody& body);
00211 void visit(const MessageFlowModeBody& body);
00212 void visit(const MessageFlowBody& body);
00213 void visit(const MessageStopBody& body);
00214 void visit(const MessageEmptyBody& body);
00215 void visit(const MessageOffsetBody& body);
00216 };
00217
00218 class AMQP_ClientOperations::ExecutionHandler::Invoker:
00219 public qpid::framing::Invoker
00220 {
00221 AMQP_ClientOperations::ExecutionHandler& target;
00222 public:
00223 Invoker(AMQP_ClientOperations::ExecutionHandler& target_) : target(target_) {}
00224 using MethodBodyDefaultVisitor::visit;
00225 void visit(const ExecutionFlushBody& body);
00226 void visit(const ExecutionCompleteBody& body);
00227 void visit(const ExecutionNoopBody& body);
00228 void visit(const ExecutionResultBody& body);
00229 void visit(const ExecutionSyncBody& body);
00230 };
00231
00232 class AMQP_ClientOperations::Connection010Handler::Invoker:
00233 public qpid::framing::Invoker
00234 {
00235 AMQP_ClientOperations::Connection010Handler& target;
00236 public:
00237 Invoker(AMQP_ClientOperations::Connection010Handler& target_) : target(target_) {}
00238 using MethodBodyDefaultVisitor::visit;
00239 void visit(const Connection010StartBody& body);
00240 void visit(const Connection010SecureBody& body);
00241 void visit(const Connection010TuneBody& body);
00242 void visit(const Connection010OpenOkBody& body);
00243 void visit(const Connection010RedirectBody& body);
00244 void visit(const Connection010CloseBody& body);
00245 void visit(const Connection010CloseOkBody& body);
00246 };
00247
00248 class AMQP_ClientOperations::Session010Handler::Invoker:
00249 public qpid::framing::Invoker
00250 {
00251 AMQP_ClientOperations::Session010Handler& target;
00252 public:
00253 Invoker(AMQP_ClientOperations::Session010Handler& target_) : target(target_) {}
00254 using MethodBodyDefaultVisitor::visit;
00255 void visit(const Session010AttachBody& body);
00256 void visit(const Session010AttachedBody& body);
00257 void visit(const Session010DetachBody& body);
00258 void visit(const Session010DetachedBody& body);
00259 void visit(const Session010RequestTimeoutBody& body);
00260 void visit(const Session010TimeoutBody& body);
00261 void visit(const Session010CommandPointBody& body);
00262 void visit(const Session010ExpectedBody& body);
00263 void visit(const Session010ConfirmedBody& body);
00264 void visit(const Session010CompletedBody& body);
00265 void visit(const Session010KnownCompletedBody& body);
00266 void visit(const Session010FlushBody& body);
00267 void visit(const Session010GapBody& body);
00268 };
00269
00270 class AMQP_ClientOperations::Execution010Handler::Invoker:
00271 public qpid::framing::Invoker
00272 {
00273 AMQP_ClientOperations::Execution010Handler& target;
00274 public:
00275 Invoker(AMQP_ClientOperations::Execution010Handler& target_) : target(target_) {}
00276 using MethodBodyDefaultVisitor::visit;
00277 void visit(const Execution010SyncBody& body);
00278 void visit(const Execution010ResultBody& body);
00279 void visit(const Execution010ExceptionBody& body);
00280 };
00281
00282 class AMQP_ClientOperations::Message010Handler::Invoker:
00283 public qpid::framing::Invoker
00284 {
00285 AMQP_ClientOperations::Message010Handler& target;
00286 public:
00287 Invoker(AMQP_ClientOperations::Message010Handler& target_) : target(target_) {}
00288 using MethodBodyDefaultVisitor::visit;
00289 void visit(const Message010TransferBody& body);
00290 void visit(const Message010AcceptBody& body);
00291 void visit(const Message010RejectBody& body);
00292 };
00293
00294 }}
00295
00296 #endif