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