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 #include "qpid/client/arg.h"
00032
00033 namespace qpid {
00034 namespace client {
00035
00188 class Session_0_10:
00189 public no_keyword::Session_0_10
00190 {
00191 public:
00192
00193 Session_0_10();
00194 Session_0_10(const SessionBase_0_10& other);
00195 Session_0_10& operator=(const SessionBase_0_10& other);
00196 private:
00197 typedef boost::parameter::parameters<arg::keyword_tags::sync> ExecutionSyncParameters;
00198
00199 typedef boost::parameter::parameters<arg::keyword_tags::commandId,arg::keyword_tags::value,arg::keyword_tags::sync> ExecutionResultParameters;
00200
00201 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,arg::keyword_tags::sync> ExecutionExceptionParameters;
00202
00203 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::acceptMode,arg::keyword_tags::acquireMode,arg::keyword_tags::content,arg::keyword_tags::sync> MessageTransferParameters;
00204
00205 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcceptParameters;
00206
00207 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::code,arg::keyword_tags::text,arg::keyword_tags::sync> MessageRejectParameters;
00208
00209 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::setRedelivered,arg::keyword_tags::sync> MessageReleaseParameters;
00210
00211 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcquireParameters;
00212
00213 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::resumeId,arg::keyword_tags::sync> MessageResumeParameters;
00214
00215 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,arg::keyword_tags::sync> MessageSubscribeParameters;
00216
00217 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageCancelParameters;
00218
00219 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::flowMode,arg::keyword_tags::sync> MessageSetFlowModeParameters;
00220
00221 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::unit,arg::keyword_tags::value,arg::keyword_tags::sync> MessageFlowParameters;
00222
00223 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageFlushParameters;
00224
00225 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageStopParameters;
00226
00227 typedef boost::parameter::parameters<arg::keyword_tags::sync> TxSelectParameters;
00228
00229 typedef boost::parameter::parameters<arg::keyword_tags::sync> TxCommitParameters;
00230
00231 typedef boost::parameter::parameters<arg::keyword_tags::sync> TxRollbackParameters;
00232
00233 typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxSelectParameters;
00234
00235 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::join,arg::keyword_tags::resume,arg::keyword_tags::sync> DtxStartParameters;
00236
00237 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::fail,arg::keyword_tags::suspend,arg::keyword_tags::sync> DtxEndParameters;
00238
00239 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::onePhase,arg::keyword_tags::sync> DtxCommitParameters;
00240
00241 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxForgetParameters;
00242
00243 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxGetTimeoutParameters;
00244
00245 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxPrepareParameters;
00246
00247 typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxRecoverParameters;
00248
00249 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxRollbackParameters;
00250
00251 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::timeout,arg::keyword_tags::sync> DtxSetTimeoutParameters;
00252
00253 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,arg::keyword_tags::sync> ExchangeDeclareParameters;
00254
00255 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::ifUnused,arg::keyword_tags::sync> ExchangeDeleteParameters;
00256
00257 typedef boost::parameter::parameters<arg::keyword_tags::name,arg::keyword_tags::sync> ExchangeQueryParameters;
00258
00259 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments,arg::keyword_tags::sync> ExchangeBindParameters;
00260
00261 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::sync> ExchangeUnbindParameters;
00262
00263 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::queue,arg::keyword_tags::bindingKey,arg::keyword_tags::arguments,arg::keyword_tags::sync> ExchangeBoundParameters;
00264
00265 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,arg::keyword_tags::sync> QueueDeclareParameters;
00266
00267 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::ifUnused,arg::keyword_tags::ifEmpty,arg::keyword_tags::sync> QueueDeleteParameters;
00268
00269 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueuePurgeParameters;
00270
00271 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueueQueryParameters;
00272
00273 friend class Connection;
00274 public:
00275 BOOST_PARAMETER_MEMFUN(void, executionSync, 0, 1, ExecutionSyncParameters) {
00276 return no_keyword::Session_0_10::executionSync(
00277 p[arg::sync|true]);
00278 }
00279
00280 BOOST_PARAMETER_MEMFUN(void, executionResult, 0, 3, ExecutionResultParameters) {
00281 return no_keyword::Session_0_10::executionResult(
00282 p[arg::commandId|SequenceNumber()],
00283 p[arg::value|string()],
00284 p[arg::sync|true]);
00285 }
00286
00287 BOOST_PARAMETER_MEMFUN(void, executionException, 0, 8, ExecutionExceptionParameters) {
00288 return no_keyword::Session_0_10::executionException(
00289 p[arg::errorCode|0],
00290 p[arg::commandId|SequenceNumber()],
00291 p[arg::classCode|0],
00292 p[arg::commandCode|0],
00293 p[arg::fieldIndex|0],
00294 p[arg::description|string()],
00295 p[arg::errorInfo|FieldTable()],
00296 p[arg::sync|true]);
00297 }
00298
00299 BOOST_PARAMETER_MEMFUN(void, messageTransfer, 0, 5, MessageTransferParameters) {
00300 return no_keyword::Session_0_10::messageTransfer(
00301 p[arg::destination|string()],
00302 p[arg::acceptMode|1],
00303 p[arg::acquireMode|0],
00304 p[arg::content|DefaultContent(std::string())],
00305 p[arg::sync|true]);
00306 }
00307
00308 BOOST_PARAMETER_MEMFUN(void, messageAccept, 0, 2, MessageAcceptParameters) {
00309 return no_keyword::Session_0_10::messageAccept(
00310 p[arg::transfers|SequenceSet()],
00311 p[arg::sync|true]);
00312 }
00313
00314 BOOST_PARAMETER_MEMFUN(void, messageReject, 0, 4, MessageRejectParameters) {
00315 return no_keyword::Session_0_10::messageReject(
00316 p[arg::transfers|SequenceSet()],
00317 p[arg::code|0],
00318 p[arg::text|string()],
00319 p[arg::sync|true]);
00320 }
00321
00322 BOOST_PARAMETER_MEMFUN(void, messageRelease, 0, 3, MessageReleaseParameters) {
00323 return no_keyword::Session_0_10::messageRelease(
00324 p[arg::transfers|SequenceSet()],
00325 p[arg::setRedelivered|false],
00326 p[arg::sync|true]);
00327 }
00328
00329 BOOST_PARAMETER_MEMFUN(qpid::framing::MessageAcquireResult, messageAcquire, 0, 2, MessageAcquireParameters) {
00330 return no_keyword::Session_0_10::messageAcquire(
00331 p[arg::transfers|SequenceSet()],
00332 p[arg::sync|true]);
00333 }
00334
00335 BOOST_PARAMETER_MEMFUN(qpid::framing::MessageResumeResult, messageResume, 0, 3, MessageResumeParameters) {
00336 return no_keyword::Session_0_10::messageResume(
00337 p[arg::destination|string()],
00338 p[arg::resumeId|string()],
00339 p[arg::sync|true]);
00340 }
00341
00342 BOOST_PARAMETER_MEMFUN(void, messageSubscribe, 0, 9, MessageSubscribeParameters) {
00343 return no_keyword::Session_0_10::messageSubscribe(
00344 p[arg::queue|string()],
00345 p[arg::destination|string()],
00346 p[arg::acceptMode|0],
00347 p[arg::acquireMode|0],
00348 p[arg::exclusive|false],
00349 p[arg::resumeId|string()],
00350 p[arg::resumeTtl|0],
00351 p[arg::arguments|FieldTable()],
00352 p[arg::sync|true]);
00353 }
00354
00355 BOOST_PARAMETER_MEMFUN(void, messageCancel, 0, 2, MessageCancelParameters) {
00356 return no_keyword::Session_0_10::messageCancel(
00357 p[arg::destination|string()],
00358 p[arg::sync|true]);
00359 }
00360
00361 BOOST_PARAMETER_MEMFUN(void, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters) {
00362 return no_keyword::Session_0_10::messageSetFlowMode(
00363 p[arg::destination|string()],
00364 p[arg::flowMode|0],
00365 p[arg::sync|true]);
00366 }
00367
00368 BOOST_PARAMETER_MEMFUN(void, messageFlow, 0, 4, MessageFlowParameters) {
00369 return no_keyword::Session_0_10::messageFlow(
00370 p[arg::destination|string()],
00371 p[arg::unit|0],
00372 p[arg::value|0],
00373 p[arg::sync|true]);
00374 }
00375
00376 BOOST_PARAMETER_MEMFUN(void, messageFlush, 0, 2, MessageFlushParameters) {
00377 return no_keyword::Session_0_10::messageFlush(
00378 p[arg::destination|string()],
00379 p[arg::sync|true]);
00380 }
00381
00382 BOOST_PARAMETER_MEMFUN(void, messageStop, 0, 2, MessageStopParameters) {
00383 return no_keyword::Session_0_10::messageStop(
00384 p[arg::destination|string()],
00385 p[arg::sync|true]);
00386 }
00387
00388 BOOST_PARAMETER_MEMFUN(void, txSelect, 0, 1, TxSelectParameters) {
00389 return no_keyword::Session_0_10::txSelect(
00390 p[arg::sync|true]);
00391 }
00392
00393 BOOST_PARAMETER_MEMFUN(void, txCommit, 0, 1, TxCommitParameters) {
00394 return no_keyword::Session_0_10::txCommit(
00395 p[arg::sync|true]);
00396 }
00397
00398 BOOST_PARAMETER_MEMFUN(void, txRollback, 0, 1, TxRollbackParameters) {
00399 return no_keyword::Session_0_10::txRollback(
00400 p[arg::sync|true]);
00401 }
00402
00403 BOOST_PARAMETER_MEMFUN(void, dtxSelect, 0, 1, DtxSelectParameters) {
00404 return no_keyword::Session_0_10::dtxSelect(
00405 p[arg::sync|true]);
00406 }
00407
00408 BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxStart, 0, 4, DtxStartParameters) {
00409 return no_keyword::Session_0_10::dtxStart(
00410 p[arg::xid|Xid()],
00411 p[arg::join|false],
00412 p[arg::resume|false],
00413 p[arg::sync|true]);
00414 }
00415
00416 BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxEnd, 0, 4, DtxEndParameters) {
00417 return no_keyword::Session_0_10::dtxEnd(
00418 p[arg::xid|Xid()],
00419 p[arg::fail|false],
00420 p[arg::suspend|false],
00421 p[arg::sync|true]);
00422 }
00423
00424 BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxCommit, 0, 3, DtxCommitParameters) {
00425 return no_keyword::Session_0_10::dtxCommit(
00426 p[arg::xid|Xid()],
00427 p[arg::onePhase|false],
00428 p[arg::sync|true]);
00429 }
00430
00431 BOOST_PARAMETER_MEMFUN(void, dtxForget, 0, 2, DtxForgetParameters) {
00432 return no_keyword::Session_0_10::dtxForget(
00433 p[arg::xid|Xid()],
00434 p[arg::sync|true]);
00435 }
00436
00437 BOOST_PARAMETER_MEMFUN(qpid::framing::DtxGetTimeoutResult, dtxGetTimeout, 0, 2, DtxGetTimeoutParameters) {
00438 return no_keyword::Session_0_10::dtxGetTimeout(
00439 p[arg::xid|Xid()],
00440 p[arg::sync|true]);
00441 }
00442
00443 BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxPrepare, 0, 2, DtxPrepareParameters) {
00444 return no_keyword::Session_0_10::dtxPrepare(
00445 p[arg::xid|Xid()],
00446 p[arg::sync|true]);
00447 }
00448
00449 BOOST_PARAMETER_MEMFUN(qpid::framing::DtxRecoverResult, dtxRecover, 0, 1, DtxRecoverParameters) {
00450 return no_keyword::Session_0_10::dtxRecover(
00451 p[arg::sync|true]);
00452 }
00453
00454 BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxRollback, 0, 2, DtxRollbackParameters) {
00455 return no_keyword::Session_0_10::dtxRollback(
00456 p[arg::xid|Xid()],
00457 p[arg::sync|true]);
00458 }
00459
00460 BOOST_PARAMETER_MEMFUN(void, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters) {
00461 return no_keyword::Session_0_10::dtxSetTimeout(
00462 p[arg::xid|Xid()],
00463 p[arg::timeout|0],
00464 p[arg::sync|true]);
00465 }
00466
00467 BOOST_PARAMETER_MEMFUN(void, exchangeDeclare, 0, 8, ExchangeDeclareParameters) {
00468 return no_keyword::Session_0_10::exchangeDeclare(
00469 p[arg::exchange|string()],
00470 p[arg::type|string()],
00471 p[arg::alternateExchange|string()],
00472 p[arg::passive|false],
00473 p[arg::durable|false],
00474 p[arg::autoDelete|false],
00475 p[arg::arguments|FieldTable()],
00476 p[arg::sync|true]);
00477 }
00478
00479 BOOST_PARAMETER_MEMFUN(void, exchangeDelete, 0, 3, ExchangeDeleteParameters) {
00480 return no_keyword::Session_0_10::exchangeDelete(
00481 p[arg::exchange|string()],
00482 p[arg::ifUnused|false],
00483 p[arg::sync|true]);
00484 }
00485
00486 BOOST_PARAMETER_MEMFUN(qpid::framing::ExchangeQueryResult, exchangeQuery, 0, 2, ExchangeQueryParameters) {
00487 return no_keyword::Session_0_10::exchangeQuery(
00488 p[arg::name|string()],
00489 p[arg::sync|true]);
00490 }
00491
00492 BOOST_PARAMETER_MEMFUN(void, exchangeBind, 0, 5, ExchangeBindParameters) {
00493 return no_keyword::Session_0_10::exchangeBind(
00494 p[arg::queue|string()],
00495 p[arg::exchange|string()],
00496 p[arg::bindingKey|string()],
00497 p[arg::arguments|FieldTable()],
00498 p[arg::sync|true]);
00499 }
00500
00501 BOOST_PARAMETER_MEMFUN(void, exchangeUnbind, 0, 4, ExchangeUnbindParameters) {
00502 return no_keyword::Session_0_10::exchangeUnbind(
00503 p[arg::queue|string()],
00504 p[arg::exchange|string()],
00505 p[arg::bindingKey|string()],
00506 p[arg::sync|true]);
00507 }
00508
00509 BOOST_PARAMETER_MEMFUN(qpid::framing::ExchangeBoundResult, exchangeBound, 0, 5, ExchangeBoundParameters) {
00510 return no_keyword::Session_0_10::exchangeBound(
00511 p[arg::exchange|string()],
00512 p[arg::queue|string()],
00513 p[arg::bindingKey|string()],
00514 p[arg::arguments|FieldTable()],
00515 p[arg::sync|true]);
00516 }
00517
00518 BOOST_PARAMETER_MEMFUN(void, queueDeclare, 0, 8, QueueDeclareParameters) {
00519 return no_keyword::Session_0_10::queueDeclare(
00520 p[arg::queue|string()],
00521 p[arg::alternateExchange|string()],
00522 p[arg::passive|false],
00523 p[arg::durable|false],
00524 p[arg::exclusive|false],
00525 p[arg::autoDelete|false],
00526 p[arg::arguments|FieldTable()],
00527 p[arg::sync|true]);
00528 }
00529
00530 BOOST_PARAMETER_MEMFUN(void, queueDelete, 0, 4, QueueDeleteParameters) {
00531 return no_keyword::Session_0_10::queueDelete(
00532 p[arg::queue|string()],
00533 p[arg::ifUnused|false],
00534 p[arg::ifEmpty|false],
00535 p[arg::sync|true]);
00536 }
00537
00538 BOOST_PARAMETER_MEMFUN(void, queuePurge, 0, 2, QueuePurgeParameters) {
00539 return no_keyword::Session_0_10::queuePurge(
00540 p[arg::queue|string()],
00541 p[arg::sync|true]);
00542 }
00543
00544 BOOST_PARAMETER_MEMFUN(qpid::framing::QueueQueryResult, queueQuery, 0, 2, QueueQueryParameters) {
00545 return no_keyword::Session_0_10::queueQuery(
00546 p[arg::queue|string()],
00547 p[arg::sync|true]);
00548 }
00549
00550 };
00552 inline Session_0_10 sync(const SessionBase_0_10& other) { return (other); }
00553
00554 inline Session_0_10::Session_0_10() {}
00555 inline Session_0_10::Session_0_10(const SessionBase_0_10& other) {
00556 *this = other;
00557 }
00558 inline Session_0_10& Session_0_10::operator=(const SessionBase_0_10& other) {
00559 impl = static_cast<const Session_0_10&>(other).impl;
00560 return *this;
00561 }
00562
00563 }}
00564
00565 #endif