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 SessionAttachBody& body);
00051 void visit(const SessionAttachedBody& body);
00052 void visit(const SessionDetachBody& body);
00053 void visit(const SessionDetachedBody& body);
00054 void visit(const SessionRequestTimeoutBody& body);
00055 void visit(const SessionTimeoutBody& body);
00056 void visit(const SessionCommandPointBody& body);
00057 void visit(const SessionExpectedBody& body);
00058 void visit(const SessionConfirmedBody& body);
00059 void visit(const SessionCompletedBody& body);
00060 void visit(const SessionKnownCompletedBody& body);
00061 void visit(const SessionFlushBody& body);
00062 void visit(const SessionGapBody& body);
00063 void visit(const ExecutionSyncBody& body);
00064 void visit(const ExecutionResultBody& body);
00065 void visit(const ExecutionExceptionBody& body);
00066 void visit(const MessageAcceptBody& body);
00067 void visit(const MessageRejectBody& body);
00068 void visit(const MessageReleaseBody& body);
00069 void visit(const MessageAcquireBody& body);
00070 void visit(const MessageResumeBody& body);
00071 void visit(const MessageSubscribeBody& body);
00072 void visit(const MessageCancelBody& body);
00073 void visit(const MessageSetFlowModeBody& body);
00074 void visit(const MessageFlowBody& body);
00075 void visit(const MessageFlushBody& body);
00076 void visit(const MessageStopBody& body);
00077 void visit(const TxSelectBody& body);
00078 void visit(const TxCommitBody& body);
00079 void visit(const TxRollbackBody& body);
00080 void visit(const DtxSelectBody& body);
00081 void visit(const DtxStartBody& body);
00082 void visit(const DtxEndBody& body);
00083 void visit(const DtxCommitBody& body);
00084 void visit(const DtxForgetBody& body);
00085 void visit(const DtxGetTimeoutBody& body);
00086 void visit(const DtxPrepareBody& body);
00087 void visit(const DtxRecoverBody& body);
00088 void visit(const DtxRollbackBody& body);
00089 void visit(const DtxSetTimeoutBody& body);
00090 void visit(const ExchangeDeclareBody& body);
00091 void visit(const ExchangeDeleteBody& body);
00092 void visit(const ExchangeQueryBody& body);
00093 void visit(const ExchangeBindBody& body);
00094 void visit(const ExchangeUnbindBody& body);
00095 void visit(const ExchangeBoundBody& body);
00096 void visit(const QueueDeclareBody& body);
00097 void visit(const QueueDeleteBody& body);
00098 void visit(const QueuePurgeBody& body);
00099 void visit(const QueueQueryBody& body);
00100 void visit(const FileQosBody& body);
00101 void visit(const FileConsumeBody& body);
00102 void visit(const FileCancelBody& body);
00103 void visit(const FileOpenBody& body);
00104 void visit(const FileOpenOkBody& body);
00105 void visit(const FilePublishBody& body);
00106 void visit(const FileAckBody& body);
00107 void visit(const FileRejectBody& body);
00108 void visit(const StreamQosBody& body);
00109 void visit(const StreamConsumeBody& body);
00110 void visit(const StreamCancelBody& body);
00111 };
00112
00113 class AMQP_ServerOperations::ConnectionHandler::Invoker:
00114 public qpid::framing::Invoker
00115 {
00116 AMQP_ServerOperations::ConnectionHandler& target;
00117 public:
00118 Invoker(AMQP_ServerOperations::ConnectionHandler& target_) : target(target_) {}
00119 using MethodBodyDefaultVisitor::visit;
00120 void visit(const ConnectionStartOkBody& body);
00121 void visit(const ConnectionSecureOkBody& body);
00122 void visit(const ConnectionTuneOkBody& body);
00123 void visit(const ConnectionOpenBody& body);
00124 void visit(const ConnectionCloseBody& body);
00125 void visit(const ConnectionCloseOkBody& body);
00126 };
00127
00128 class AMQP_ServerOperations::SessionHandler::Invoker:
00129 public qpid::framing::Invoker
00130 {
00131 AMQP_ServerOperations::SessionHandler& target;
00132 public:
00133 Invoker(AMQP_ServerOperations::SessionHandler& target_) : target(target_) {}
00134 using MethodBodyDefaultVisitor::visit;
00135 void visit(const SessionAttachBody& body);
00136 void visit(const SessionAttachedBody& body);
00137 void visit(const SessionDetachBody& body);
00138 void visit(const SessionDetachedBody& body);
00139 void visit(const SessionRequestTimeoutBody& body);
00140 void visit(const SessionTimeoutBody& body);
00141 void visit(const SessionCommandPointBody& body);
00142 void visit(const SessionExpectedBody& body);
00143 void visit(const SessionConfirmedBody& body);
00144 void visit(const SessionCompletedBody& body);
00145 void visit(const SessionKnownCompletedBody& body);
00146 void visit(const SessionFlushBody& body);
00147 void visit(const SessionGapBody& body);
00148 };
00149
00150 class AMQP_ServerOperations::ExecutionHandler::Invoker:
00151 public qpid::framing::Invoker
00152 {
00153 AMQP_ServerOperations::ExecutionHandler& target;
00154 public:
00155 Invoker(AMQP_ServerOperations::ExecutionHandler& target_) : target(target_) {}
00156 using MethodBodyDefaultVisitor::visit;
00157 void visit(const ExecutionSyncBody& body);
00158 void visit(const ExecutionResultBody& body);
00159 void visit(const ExecutionExceptionBody& body);
00160 };
00161
00162 class AMQP_ServerOperations::MessageHandler::Invoker:
00163 public qpid::framing::Invoker
00164 {
00165 AMQP_ServerOperations::MessageHandler& target;
00166 public:
00167 Invoker(AMQP_ServerOperations::MessageHandler& target_) : target(target_) {}
00168 using MethodBodyDefaultVisitor::visit;
00169 void visit(const MessageAcceptBody& body);
00170 void visit(const MessageRejectBody& body);
00171 void visit(const MessageReleaseBody& body);
00172 void visit(const MessageAcquireBody& body);
00173 void visit(const MessageResumeBody& body);
00174 void visit(const MessageSubscribeBody& body);
00175 void visit(const MessageCancelBody& body);
00176 void visit(const MessageSetFlowModeBody& body);
00177 void visit(const MessageFlowBody& body);
00178 void visit(const MessageFlushBody& body);
00179 void visit(const MessageStopBody& body);
00180 };
00181
00182 class AMQP_ServerOperations::TxHandler::Invoker:
00183 public qpid::framing::Invoker
00184 {
00185 AMQP_ServerOperations::TxHandler& target;
00186 public:
00187 Invoker(AMQP_ServerOperations::TxHandler& target_) : target(target_) {}
00188 using MethodBodyDefaultVisitor::visit;
00189 void visit(const TxSelectBody& body);
00190 void visit(const TxCommitBody& body);
00191 void visit(const TxRollbackBody& body);
00192 };
00193
00194 class AMQP_ServerOperations::DtxHandler::Invoker:
00195 public qpid::framing::Invoker
00196 {
00197 AMQP_ServerOperations::DtxHandler& target;
00198 public:
00199 Invoker(AMQP_ServerOperations::DtxHandler& target_) : target(target_) {}
00200 using MethodBodyDefaultVisitor::visit;
00201 void visit(const DtxSelectBody& body);
00202 void visit(const DtxStartBody& body);
00203 void visit(const DtxEndBody& body);
00204 void visit(const DtxCommitBody& body);
00205 void visit(const DtxForgetBody& body);
00206 void visit(const DtxGetTimeoutBody& body);
00207 void visit(const DtxPrepareBody& body);
00208 void visit(const DtxRecoverBody& body);
00209 void visit(const DtxRollbackBody& body);
00210 void visit(const DtxSetTimeoutBody& body);
00211 };
00212
00213 class AMQP_ServerOperations::ExchangeHandler::Invoker:
00214 public qpid::framing::Invoker
00215 {
00216 AMQP_ServerOperations::ExchangeHandler& target;
00217 public:
00218 Invoker(AMQP_ServerOperations::ExchangeHandler& target_) : target(target_) {}
00219 using MethodBodyDefaultVisitor::visit;
00220 void visit(const ExchangeDeclareBody& body);
00221 void visit(const ExchangeDeleteBody& body);
00222 void visit(const ExchangeQueryBody& body);
00223 void visit(const ExchangeBindBody& body);
00224 void visit(const ExchangeUnbindBody& body);
00225 void visit(const ExchangeBoundBody& body);
00226 };
00227
00228 class AMQP_ServerOperations::QueueHandler::Invoker:
00229 public qpid::framing::Invoker
00230 {
00231 AMQP_ServerOperations::QueueHandler& target;
00232 public:
00233 Invoker(AMQP_ServerOperations::QueueHandler& target_) : target(target_) {}
00234 using MethodBodyDefaultVisitor::visit;
00235 void visit(const QueueDeclareBody& body);
00236 void visit(const QueueDeleteBody& body);
00237 void visit(const QueuePurgeBody& body);
00238 void visit(const QueueQueryBody& body);
00239 };
00240
00241 class AMQP_ServerOperations::FileHandler::Invoker:
00242 public qpid::framing::Invoker
00243 {
00244 AMQP_ServerOperations::FileHandler& target;
00245 public:
00246 Invoker(AMQP_ServerOperations::FileHandler& target_) : target(target_) {}
00247 using MethodBodyDefaultVisitor::visit;
00248 void visit(const FileQosBody& body);
00249 void visit(const FileConsumeBody& body);
00250 void visit(const FileCancelBody& body);
00251 void visit(const FileOpenBody& body);
00252 void visit(const FileOpenOkBody& body);
00253 void visit(const FilePublishBody& body);
00254 void visit(const FileAckBody& body);
00255 void visit(const FileRejectBody& body);
00256 };
00257
00258 class AMQP_ServerOperations::StreamHandler::Invoker:
00259 public qpid::framing::Invoker
00260 {
00261 AMQP_ServerOperations::StreamHandler& target;
00262 public:
00263 Invoker(AMQP_ServerOperations::StreamHandler& target_) : target(target_) {}
00264 using MethodBodyDefaultVisitor::visit;
00265 void visit(const StreamQosBody& body);
00266 void visit(const StreamConsumeBody& body);
00267 void visit(const StreamCancelBody& body);
00268 };
00269
00270 }}
00271
00272 #endif