00001 #ifndef QPID_CLIENT_SESSION_0_10_H
00002 #define QPID_CLIENT_SESSION_0_10_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/client/no_keyword/Session_0_10.h"
00031
00032 #define BOOST_PARAMETER_MAX_ARITY 8
00033 #include <boost/parameter.hpp>
00034
00035
00036 namespace qpid {
00037 namespace client {
00038
00039
00040 namespace arg {
00041
00042 BOOST_PARAMETER_KEYWORD(keyword_tags, commandId)
00043 BOOST_PARAMETER_KEYWORD(keyword_tags, value)
00044 BOOST_PARAMETER_KEYWORD(keyword_tags, errorCode)
00045 BOOST_PARAMETER_KEYWORD(keyword_tags, classCode)
00046 BOOST_PARAMETER_KEYWORD(keyword_tags, commandCode)
00047 BOOST_PARAMETER_KEYWORD(keyword_tags, fieldIndex)
00048 BOOST_PARAMETER_KEYWORD(keyword_tags, description)
00049 BOOST_PARAMETER_KEYWORD(keyword_tags, errorInfo)
00050 BOOST_PARAMETER_KEYWORD(keyword_tags, destination)
00051 BOOST_PARAMETER_KEYWORD(keyword_tags, acceptMode)
00052 BOOST_PARAMETER_KEYWORD(keyword_tags, acquireMode)
00053 BOOST_PARAMETER_KEYWORD(keyword_tags, content)
00054 BOOST_PARAMETER_KEYWORD(keyword_tags, transfers)
00055 BOOST_PARAMETER_KEYWORD(keyword_tags, code)
00056 BOOST_PARAMETER_KEYWORD(keyword_tags, text)
00057 BOOST_PARAMETER_KEYWORD(keyword_tags, setRedelivered)
00058 BOOST_PARAMETER_KEYWORD(keyword_tags, resumeId)
00059 BOOST_PARAMETER_KEYWORD(keyword_tags, queue)
00060 BOOST_PARAMETER_KEYWORD(keyword_tags, exclusive)
00061 BOOST_PARAMETER_KEYWORD(keyword_tags, resumeTtl)
00062 BOOST_PARAMETER_KEYWORD(keyword_tags, arguments)
00063 BOOST_PARAMETER_KEYWORD(keyword_tags, flowMode)
00064 BOOST_PARAMETER_KEYWORD(keyword_tags, unit)
00065 BOOST_PARAMETER_KEYWORD(keyword_tags, xid)
00066 BOOST_PARAMETER_KEYWORD(keyword_tags, join)
00067 BOOST_PARAMETER_KEYWORD(keyword_tags, resume)
00068 BOOST_PARAMETER_KEYWORD(keyword_tags, fail)
00069 BOOST_PARAMETER_KEYWORD(keyword_tags, suspend)
00070 BOOST_PARAMETER_KEYWORD(keyword_tags, onePhase)
00071 BOOST_PARAMETER_KEYWORD(keyword_tags, timeout)
00072 BOOST_PARAMETER_KEYWORD(keyword_tags, exchange)
00073 BOOST_PARAMETER_KEYWORD(keyword_tags, type)
00074 BOOST_PARAMETER_KEYWORD(keyword_tags, alternateExchange)
00075 BOOST_PARAMETER_KEYWORD(keyword_tags, passive)
00076 BOOST_PARAMETER_KEYWORD(keyword_tags, durable)
00077 BOOST_PARAMETER_KEYWORD(keyword_tags, autoDelete)
00078 BOOST_PARAMETER_KEYWORD(keyword_tags, ifUnused)
00079 BOOST_PARAMETER_KEYWORD(keyword_tags, name)
00080 BOOST_PARAMETER_KEYWORD(keyword_tags, bindingKey)
00081 BOOST_PARAMETER_KEYWORD(keyword_tags, ifEmpty)
00082
00083 }
00084
00085
00108 class Session_0_10:
00109 public no_keyword::Session_0_10
00110 {
00111 private:
00112 Session_0_10(shared_ptr<SessionImpl> core) : no_keyword::Session_0_10(core) {}
00113 typedef boost::parameter::parameters<arg::keyword_tags::commandId,arg::keyword_tags::value> ExecutionResultParameters;
00114
00115 typedef boost::parameter::parameters<arg::keyword_tags::errorCode,arg::keyword_tags::commandId,arg::keyword_tags::classCode,arg::keyword_tags::commandCode,arg::keyword_tags::fieldIndex,arg::keyword_tags::description,arg::keyword_tags::errorInfo> ExecutionExceptionParameters;
00116
00117 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::acceptMode,arg::keyword_tags::acquireMode,arg::keyword_tags::content> MessageTransferParameters;
00118
00119 typedef boost::parameter::parameters<arg::keyword_tags::transfers> MessageAcceptParameters;
00120
00121 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::code,arg::keyword_tags::text> MessageRejectParameters;
00122
00123 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::setRedelivered> MessageReleaseParameters;
00124
00125 typedef boost::parameter::parameters<arg::keyword_tags::transfers> MessageAcquireParameters;
00126
00127 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::resumeId> MessageResumeParameters;
00128
00129 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::destination,arg::keyword_tags::acceptMode,arg::keyword_tags::acquireMode,arg::keyword_tags::exclusive,arg::keyword_tags::resumeId,arg::keyword_tags::resumeTtl,arg::keyword_tags::arguments> MessageSubscribeParameters;
00130
00131 typedef boost::parameter::parameters<arg::keyword_tags::destination> MessageCancelParameters;
00132
00133 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::flowMode> MessageSetFlowModeParameters;
00134
00135 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::unit,arg::keyword_tags::value> MessageFlowParameters;
00136
00137 typedef boost::parameter::parameters<arg::keyword_tags::destination> MessageFlushParameters;
00138
00139 typedef boost::parameter::parameters<arg::keyword_tags::destination> MessageStopParameters;
00140
00141 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::join,arg::keyword_tags::resume> DtxStartParameters;
00142
00143 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::fail,arg::keyword_tags::suspend> DtxEndParameters;
00144
00145 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::onePhase> DtxCommitParameters;
00146
00147 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxForgetParameters;
00148
00149 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxGetTimeoutParameters;
00150
00151 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxPrepareParameters;
00152
00153 typedef boost::parameter::parameters<arg::keyword_tags::xid> DtxRollbackParameters;
00154
00155 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::timeout> DtxSetTimeoutParameters;
00156
00157 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::type,arg::keyword_tags::alternateExchange,arg::keyword_tags::passive,arg::keyword_tags::durable,arg::keyword_tags::autoDelete,arg::keyword_tags::arguments> ExchangeDeclareParameters;
00158
00159 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::ifUnused> ExchangeDeleteParameters;
00160
00161 typedef boost::parameter::parameters<arg::keyword_tags::name> ExchangeQueryParameters;
00162
00163 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments> ExchangeBindParameters;
00164
00165 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey> ExchangeUnbindParameters;
00166
00167 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::queue,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments> ExchangeBoundParameters;
00168
00169 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::alternateExchange,arg::keyword_tags::passive,arg::keyword_tags::durable,arg::keyword_tags::exclusive,arg::keyword_tags::autoDelete,arg::keyword_tags::arguments> QueueDeclareParameters;
00170
00171 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::ifUnused,arg::keyword_tags::ifEmpty> QueueDeleteParameters;
00172
00173 typedef boost::parameter::parameters<arg::keyword_tags::queue> QueuePurgeParameters;
00174
00175 typedef boost::parameter::parameters<arg::keyword_tags::queue> QueueQueryParameters;
00176
00177 friend class Connection;
00178 public:
00179 Session_0_10() {}
00180 BOOST_PARAMETER_MEMFUN(Completion, executionResult, 0, 2, ExecutionResultParameters) {
00181 return no_keyword::Session_0_10::executionResult(
00182 p[arg::commandId|SequenceNumber()],
00183 p[arg::value|string()]);
00184 }
00185
00186 BOOST_PARAMETER_MEMFUN(Completion, executionException, 0, 7, ExecutionExceptionParameters) {
00187 return no_keyword::Session_0_10::executionException(
00188 p[arg::errorCode|0],
00189 p[arg::commandId|SequenceNumber()],
00190 p[arg::classCode|0],
00191 p[arg::commandCode|0],
00192 p[arg::fieldIndex|0],
00193 p[arg::description|string()],
00194 p[arg::errorInfo|FieldTable()]);
00195 }
00196
00197 BOOST_PARAMETER_MEMFUN(Completion, messageTransfer, 0, 4, MessageTransferParameters) {
00198 return no_keyword::Session_0_10::messageTransfer(
00199 p[arg::destination|string()],
00200 p[arg::acceptMode|0],
00201 p[arg::acquireMode|0],
00202 p[arg::content|DefaultContent(std::string())]);
00203 }
00204
00205 BOOST_PARAMETER_MEMFUN(Completion, messageAccept, 0, 1, MessageAcceptParameters) {
00206 return no_keyword::Session_0_10::messageAccept(
00207 p[arg::transfers|SequenceSet()]);
00208 }
00209
00210 BOOST_PARAMETER_MEMFUN(Completion, messageReject, 0, 3, MessageRejectParameters) {
00211 return no_keyword::Session_0_10::messageReject(
00212 p[arg::transfers|SequenceSet()],
00213 p[arg::code|0],
00214 p[arg::text|string()]);
00215 }
00216
00217 BOOST_PARAMETER_MEMFUN(Completion, messageRelease, 0, 2, MessageReleaseParameters) {
00218 return no_keyword::Session_0_10::messageRelease(
00219 p[arg::transfers|SequenceSet()],
00220 p[arg::setRedelivered|false]);
00221 }
00222
00223 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::MessageAcquireResult>, messageAcquire, 0, 1, MessageAcquireParameters) {
00224 return no_keyword::Session_0_10::messageAcquire(
00225 p[arg::transfers|SequenceSet()]);
00226 }
00227
00228 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::MessageResumeResult>, messageResume, 0, 2, MessageResumeParameters) {
00229 return no_keyword::Session_0_10::messageResume(
00230 p[arg::destination|string()],
00231 p[arg::resumeId|string()]);
00232 }
00233
00234 BOOST_PARAMETER_MEMFUN(Completion, messageSubscribe, 0, 8, MessageSubscribeParameters) {
00235 return no_keyword::Session_0_10::messageSubscribe(
00236 p[arg::queue|string()],
00237 p[arg::destination|string()],
00238 p[arg::acceptMode|0],
00239 p[arg::acquireMode|0],
00240 p[arg::exclusive|false],
00241 p[arg::resumeId|string()],
00242 p[arg::resumeTtl|0],
00243 p[arg::arguments|FieldTable()]);
00244 }
00245
00246 BOOST_PARAMETER_MEMFUN(Completion, messageCancel, 0, 1, MessageCancelParameters) {
00247 return no_keyword::Session_0_10::messageCancel(
00248 p[arg::destination|string()]);
00249 }
00250
00251 BOOST_PARAMETER_MEMFUN(Completion, messageSetFlowMode, 0, 2, MessageSetFlowModeParameters) {
00252 return no_keyword::Session_0_10::messageSetFlowMode(
00253 p[arg::destination|string()],
00254 p[arg::flowMode|0]);
00255 }
00256
00257 BOOST_PARAMETER_MEMFUN(Completion, messageFlow, 0, 3, MessageFlowParameters) {
00258 return no_keyword::Session_0_10::messageFlow(
00259 p[arg::destination|string()],
00260 p[arg::unit|0],
00261 p[arg::value|0]);
00262 }
00263
00264 BOOST_PARAMETER_MEMFUN(Completion, messageFlush, 0, 1, MessageFlushParameters) {
00265 return no_keyword::Session_0_10::messageFlush(
00266 p[arg::destination|string()]);
00267 }
00268
00269 BOOST_PARAMETER_MEMFUN(Completion, messageStop, 0, 1, MessageStopParameters) {
00270 return no_keyword::Session_0_10::messageStop(
00271 p[arg::destination|string()]);
00272 }
00273
00274 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxStart, 0, 3, DtxStartParameters) {
00275 return no_keyword::Session_0_10::dtxStart(
00276 p[arg::xid|Xid()],
00277 p[arg::join|false],
00278 p[arg::resume|false]);
00279 }
00280
00281 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxEnd, 0, 3, DtxEndParameters) {
00282 return no_keyword::Session_0_10::dtxEnd(
00283 p[arg::xid|Xid()],
00284 p[arg::fail|false],
00285 p[arg::suspend|false]);
00286 }
00287
00288 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxCommit, 0, 2, DtxCommitParameters) {
00289 return no_keyword::Session_0_10::dtxCommit(
00290 p[arg::xid|Xid()],
00291 p[arg::onePhase|false]);
00292 }
00293
00294 BOOST_PARAMETER_MEMFUN(Completion, dtxForget, 0, 1, DtxForgetParameters) {
00295 return no_keyword::Session_0_10::dtxForget(
00296 p[arg::xid|Xid()]);
00297 }
00298
00299 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::DtxGetTimeoutResult>, dtxGetTimeout, 0, 1, DtxGetTimeoutParameters) {
00300 return no_keyword::Session_0_10::dtxGetTimeout(
00301 p[arg::xid|Xid()]);
00302 }
00303
00304 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxPrepare, 0, 1, DtxPrepareParameters) {
00305 return no_keyword::Session_0_10::dtxPrepare(
00306 p[arg::xid|Xid()]);
00307 }
00308
00309 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::XaResult>, dtxRollback, 0, 1, DtxRollbackParameters) {
00310 return no_keyword::Session_0_10::dtxRollback(
00311 p[arg::xid|Xid()]);
00312 }
00313
00314 BOOST_PARAMETER_MEMFUN(Completion, dtxSetTimeout, 0, 2, DtxSetTimeoutParameters) {
00315 return no_keyword::Session_0_10::dtxSetTimeout(
00316 p[arg::xid|Xid()],
00317 p[arg::timeout|0]);
00318 }
00319
00320 BOOST_PARAMETER_MEMFUN(Completion, exchangeDeclare, 0, 7, ExchangeDeclareParameters) {
00321 return no_keyword::Session_0_10::exchangeDeclare(
00322 p[arg::exchange|string()],
00323 p[arg::type|string()],
00324 p[arg::alternateExchange|string()],
00325 p[arg::passive|false],
00326 p[arg::durable|false],
00327 p[arg::autoDelete|false],
00328 p[arg::arguments|FieldTable()]);
00329 }
00330
00331 BOOST_PARAMETER_MEMFUN(Completion, exchangeDelete, 0, 2, ExchangeDeleteParameters) {
00332 return no_keyword::Session_0_10::exchangeDelete(
00333 p[arg::exchange|string()],
00334 p[arg::ifUnused|false]);
00335 }
00336
00337 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::ExchangeQueryResult>, exchangeQuery, 0, 1, ExchangeQueryParameters) {
00338 return no_keyword::Session_0_10::exchangeQuery(
00339 p[arg::name|string()]);
00340 }
00341
00342 BOOST_PARAMETER_MEMFUN(Completion, exchangeBind, 0, 4, ExchangeBindParameters) {
00343 return no_keyword::Session_0_10::exchangeBind(
00344 p[arg::queue|string()],
00345 p[arg::exchange|string()],
00346 p[arg::bindingKey|string()],
00347 p[arg::arguments|FieldTable()]);
00348 }
00349
00350 BOOST_PARAMETER_MEMFUN(Completion, exchangeUnbind, 0, 3, ExchangeUnbindParameters) {
00351 return no_keyword::Session_0_10::exchangeUnbind(
00352 p[arg::queue|string()],
00353 p[arg::exchange|string()],
00354 p[arg::bindingKey|string()]);
00355 }
00356
00357 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::ExchangeBoundResult>, exchangeBound, 0, 4, ExchangeBoundParameters) {
00358 return no_keyword::Session_0_10::exchangeBound(
00359 p[arg::exchange|string()],
00360 p[arg::queue|string()],
00361 p[arg::bindingKey|string()],
00362 p[arg::arguments|FieldTable()]);
00363 }
00364
00365 BOOST_PARAMETER_MEMFUN(Completion, queueDeclare, 0, 7, QueueDeclareParameters) {
00366 return no_keyword::Session_0_10::queueDeclare(
00367 p[arg::queue|string()],
00368 p[arg::alternateExchange|string()],
00369 p[arg::passive|false],
00370 p[arg::durable|false],
00371 p[arg::exclusive|false],
00372 p[arg::autoDelete|false],
00373 p[arg::arguments|FieldTable()]);
00374 }
00375
00376 BOOST_PARAMETER_MEMFUN(Completion, queueDelete, 0, 3, QueueDeleteParameters) {
00377 return no_keyword::Session_0_10::queueDelete(
00378 p[arg::queue|string()],
00379 p[arg::ifUnused|false],
00380 p[arg::ifEmpty|false]);
00381 }
00382
00383 BOOST_PARAMETER_MEMFUN(Completion, queuePurge, 0, 1, QueuePurgeParameters) {
00384 return no_keyword::Session_0_10::queuePurge(
00385 p[arg::queue|string()]);
00386 }
00387
00388 BOOST_PARAMETER_MEMFUN(TypedResult<qpid::framing::QueueQueryResult>, queueQuery, 0, 1, QueueQueryParameters) {
00389 return no_keyword::Session_0_10::queueQuery(
00390 p[arg::queue|string()]);
00391 }
00392
00393 };
00394
00395 }}
00396
00397 #endif