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 SessionAttachBody& body);
00052 void visit(const SessionAttachedBody& body);
00053 void visit(const SessionDetachBody& body);
00054 void visit(const SessionDetachedBody& body);
00055 void visit(const SessionRequestTimeoutBody& body);
00056 void visit(const SessionTimeoutBody& body);
00057 void visit(const SessionCommandPointBody& body);
00058 void visit(const SessionExpectedBody& body);
00059 void visit(const SessionConfirmedBody& body);
00060 void visit(const SessionCompletedBody& body);
00061 void visit(const SessionKnownCompletedBody& body);
00062 void visit(const SessionFlushBody& body);
00063 void visit(const SessionGapBody& body);
00064 void visit(const ExecutionSyncBody& body);
00065 void visit(const ExecutionResultBody& body);
00066 void visit(const ExecutionExceptionBody& body);
00067 void visit(const MessageAcceptBody& body);
00068 void visit(const MessageRejectBody& body);
00069 void visit(const MessageReleaseBody& body);
00070 void visit(const MessageResumeBody& body);
00071 void visit(const MessageSetFlowModeBody& body);
00072 void visit(const MessageFlowBody& body);
00073 void visit(const MessageStopBody& body);
00074 void visit(const FileQosOkBody& body);
00075 void visit(const FileConsumeOkBody& body);
00076 void visit(const FileOpenBody& body);
00077 void visit(const FileOpenOkBody& body);
00078 void visit(const FileDeliverBody& body);
00079 void visit(const StreamQosOkBody& body);
00080 void visit(const StreamConsumeOkBody& body);
00081 };
00082
00083 class AMQP_ClientOperations::ConnectionHandler::Invoker:
00084 public qpid::framing::Invoker
00085 {
00086 AMQP_ClientOperations::ConnectionHandler& target;
00087 public:
00088 Invoker(AMQP_ClientOperations::ConnectionHandler& target_) : target(target_) {}
00089 using MethodBodyDefaultVisitor::visit;
00090 void visit(const ConnectionStartBody& body);
00091 void visit(const ConnectionSecureBody& body);
00092 void visit(const ConnectionTuneBody& body);
00093 void visit(const ConnectionOpenOkBody& body);
00094 void visit(const ConnectionRedirectBody& body);
00095 void visit(const ConnectionCloseBody& body);
00096 void visit(const ConnectionCloseOkBody& body);
00097 };
00098
00099 class AMQP_ClientOperations::SessionHandler::Invoker:
00100 public qpid::framing::Invoker
00101 {
00102 AMQP_ClientOperations::SessionHandler& target;
00103 public:
00104 Invoker(AMQP_ClientOperations::SessionHandler& target_) : target(target_) {}
00105 using MethodBodyDefaultVisitor::visit;
00106 void visit(const SessionAttachBody& body);
00107 void visit(const SessionAttachedBody& body);
00108 void visit(const SessionDetachBody& body);
00109 void visit(const SessionDetachedBody& body);
00110 void visit(const SessionRequestTimeoutBody& body);
00111 void visit(const SessionTimeoutBody& body);
00112 void visit(const SessionCommandPointBody& body);
00113 void visit(const SessionExpectedBody& body);
00114 void visit(const SessionConfirmedBody& body);
00115 void visit(const SessionCompletedBody& body);
00116 void visit(const SessionKnownCompletedBody& body);
00117 void visit(const SessionFlushBody& body);
00118 void visit(const SessionGapBody& body);
00119 };
00120
00121 class AMQP_ClientOperations::ExecutionHandler::Invoker:
00122 public qpid::framing::Invoker
00123 {
00124 AMQP_ClientOperations::ExecutionHandler& target;
00125 public:
00126 Invoker(AMQP_ClientOperations::ExecutionHandler& target_) : target(target_) {}
00127 using MethodBodyDefaultVisitor::visit;
00128 void visit(const ExecutionSyncBody& body);
00129 void visit(const ExecutionResultBody& body);
00130 void visit(const ExecutionExceptionBody& body);
00131 };
00132
00133 class AMQP_ClientOperations::MessageHandler::Invoker:
00134 public qpid::framing::Invoker
00135 {
00136 AMQP_ClientOperations::MessageHandler& target;
00137 public:
00138 Invoker(AMQP_ClientOperations::MessageHandler& target_) : target(target_) {}
00139 using MethodBodyDefaultVisitor::visit;
00140 void visit(const MessageAcceptBody& body);
00141 void visit(const MessageRejectBody& body);
00142 void visit(const MessageReleaseBody& body);
00143 void visit(const MessageResumeBody& body);
00144 void visit(const MessageSetFlowModeBody& body);
00145 void visit(const MessageFlowBody& body);
00146 void visit(const MessageStopBody& body);
00147 };
00148
00149 class AMQP_ClientOperations::FileHandler::Invoker:
00150 public qpid::framing::Invoker
00151 {
00152 AMQP_ClientOperations::FileHandler& target;
00153 public:
00154 Invoker(AMQP_ClientOperations::FileHandler& target_) : target(target_) {}
00155 using MethodBodyDefaultVisitor::visit;
00156 void visit(const FileQosOkBody& body);
00157 void visit(const FileConsumeOkBody& body);
00158 void visit(const FileOpenBody& body);
00159 void visit(const FileOpenOkBody& body);
00160 void visit(const FileDeliverBody& body);
00161 };
00162
00163 class AMQP_ClientOperations::StreamHandler::Invoker:
00164 public qpid::framing::Invoker
00165 {
00166 AMQP_ClientOperations::StreamHandler& target;
00167 public:
00168 Invoker(AMQP_ClientOperations::StreamHandler& target_) : target(target_) {}
00169 using MethodBodyDefaultVisitor::visit;
00170 void visit(const StreamQosOkBody& body);
00171 void visit(const StreamConsumeOkBody& body);
00172 };
00173
00174 }}
00175
00176 #endif