1 #ifndef QPID_CLIENT_ASYNCSESSION_0_10_H
2 #define QPID_CLIENT_ASYNCSESSION_0_10_H
32 #include "qpid/client/ClientImportExport.h"
196 QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10&
operator=(
const SessionBase_0_10& other);
198 typedef boost::parameter::parameters<arg::keyword_tags::sync> ExecutionSyncParameters;
200 typedef boost::parameter::parameters<arg::keyword_tags::commandId,arg::keyword_tags::value,arg::keyword_tags::sync> ExecutionResultParameters;
202 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;
204 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;
206 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcceptParameters;
208 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::code,arg::keyword_tags::text,arg::keyword_tags::sync> MessageRejectParameters;
210 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::setRedelivered,arg::keyword_tags::sync> MessageReleaseParameters;
212 typedef boost::parameter::parameters<arg::keyword_tags::transfers,arg::keyword_tags::sync> MessageAcquireParameters;
214 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::resumeId,arg::keyword_tags::sync> MessageResumeParameters;
216 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;
218 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageCancelParameters;
220 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::flowMode,arg::keyword_tags::sync> MessageSetFlowModeParameters;
222 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::unit,arg::keyword_tags::value,arg::keyword_tags::sync> MessageFlowParameters;
224 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageFlushParameters;
226 typedef boost::parameter::parameters<arg::keyword_tags::destination,arg::keyword_tags::sync> MessageStopParameters;
228 typedef boost::parameter::parameters<arg::keyword_tags::sync> TxSelectParameters;
230 typedef boost::parameter::parameters<arg::keyword_tags::sync> TxCommitParameters;
232 typedef boost::parameter::parameters<arg::keyword_tags::sync> TxRollbackParameters;
234 typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxSelectParameters;
236 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::join,arg::keyword_tags::resume,arg::keyword_tags::sync> DtxStartParameters;
238 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::fail,arg::keyword_tags::suspend,arg::keyword_tags::sync> DtxEndParameters;
240 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::onePhase,arg::keyword_tags::sync> DtxCommitParameters;
242 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxForgetParameters;
244 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxGetTimeoutParameters;
246 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxPrepareParameters;
248 typedef boost::parameter::parameters<arg::keyword_tags::sync> DtxRecoverParameters;
250 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::sync> DtxRollbackParameters;
252 typedef boost::parameter::parameters<arg::keyword_tags::xid,arg::keyword_tags::timeout,arg::keyword_tags::sync> DtxSetTimeoutParameters;
254 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;
256 typedef boost::parameter::parameters<arg::keyword_tags::exchange,arg::keyword_tags::ifUnused,arg::keyword_tags::sync> ExchangeDeleteParameters;
258 typedef boost::parameter::parameters<arg::keyword_tags::name,arg::keyword_tags::sync> ExchangeQueryParameters;
260 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;
262 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::exchange,arg::keyword_tags::bindingKey,arg::keyword_tags::sync> ExchangeUnbindParameters;
264 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;
266 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;
268 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::ifUnused,arg::keyword_tags::ifEmpty,arg::keyword_tags::sync> QueueDeleteParameters;
270 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueuePurgeParameters;
272 typedef boost::parameter::parameters<arg::keyword_tags::queue,arg::keyword_tags::sync> QueueQueryParameters;
283 p[arg::commandId|SequenceNumber()],
284 p[arg::value|std::string()],
291 p[arg::commandId|SequenceNumber()],
293 p[arg::commandCode|0],
294 p[arg::fieldIndex|0],
295 p[arg::description|std::string()],
296 p[arg::errorInfo|FieldTable()],
302 p[arg::destination|std::string()],
303 p[arg::acceptMode|1],
304 p[arg::acquireMode|0],
305 p[arg::content|Message(std::string())],
311 p[arg::transfers|SequenceSet()],
317 p[arg::transfers|SequenceSet()],
319 p[arg::text|std::string()],
325 p[arg::transfers|SequenceSet()],
326 p[arg::setRedelivered|
false],
332 p[arg::transfers|SequenceSet()],
338 p[arg::destination|std::string()],
339 p[arg::resumeId|std::string()],
345 p[arg::queue|std::string()],
346 p[arg::destination|std::string()],
347 p[arg::acceptMode|0],
348 p[arg::acquireMode|0],
349 p[arg::exclusive|
false],
350 p[arg::resumeId|std::string()],
352 p[arg::arguments|FieldTable()],
358 p[arg::destination|std::string()],
364 p[arg::destination|std::string()],
371 p[arg::destination|std::string()],
379 p[arg::destination|std::string()],
385 p[arg::destination|std::string()],
413 p[arg::resume|
false],
421 p[arg::suspend|
false],
428 p[arg::onePhase|
false],
470 p[arg::exchange|std::string()],
471 p[arg::type|std::string()],
472 p[arg::alternateExchange|std::string()],
473 p[arg::passive|
false],
474 p[arg::durable|
false],
475 p[arg::autoDelete|
false],
476 p[arg::arguments|FieldTable()],
482 p[arg::exchange|std::string()],
483 p[arg::ifUnused|
false],
489 p[arg::name|std::string()],
495 p[arg::queue|std::string()],
496 p[arg::exchange|std::string()],
497 p[arg::bindingKey|std::string()],
498 p[arg::arguments|FieldTable()],
504 p[arg::queue|std::string()],
505 p[arg::exchange|std::string()],
506 p[arg::bindingKey|std::string()],
512 p[arg::exchange|std::string()],
513 p[arg::queue|std::string()],
514 p[arg::bindingKey|std::string()],
515 p[arg::arguments|FieldTable()],
521 p[arg::queue|std::string()],
522 p[arg::alternateExchange|std::string()],
523 p[arg::passive|
false],
524 p[arg::durable|
false],
525 p[arg::exclusive|
false],
526 p[arg::autoDelete|
false],
527 p[arg::arguments|FieldTable()],
533 p[arg::queue|std::string()],
534 p[arg::ifUnused|
false],
535 p[arg::ifEmpty|
false],
541 p[arg::queue|std::string()],
547 p[arg::queue|std::string()],
BOOST_PARAMETER_MEMFUN(Completion, exchangeUnbind, 0, 4, ExchangeUnbindParameters)
TypedResult< qpid::framing::XaResult > dtxRollback(const Xid &xid=Xid(), bool sync=false)
Completion executionResult(const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=false)
Completion queueDelete(const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, messageFlow, 0, 4, MessageFlowParameters)
Completion messageSetFlowMode(const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=false)
TypedResult< qpid::framing::ExchangeQueryResult > exchangeQuery(const std::string &name=std::string(), bool sync=false)
Completion messageFlush(const std::string &destination=std::string(), bool sync=false)
Completion messageCancel(const std::string &destination=std::string(), bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters)
TypedResult< qpid::framing::ExchangeBoundResult > exchangeBound(const std::string &exchange=std::string(), const std::string &queue=std::string(), const std::string &bindingKey=std::string(), const FieldTable &arguments=FieldTable(), bool sync=false)
Completion queuePurge(const std::string &queue=std::string(), bool sync=false)
TypedResult< qpid::framing::DtxGetTimeoutResult > dtxGetTimeout(const Xid &xid=Xid(), bool sync=false)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::ExchangeQueryResult >, exchangeQuery, 0, 2, ExchangeQueryParameters)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::XaResult >, dtxPrepare, 0, 2, DtxPrepareParameters)
Completion exchangeUnbind(const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, dtxSelect, 0, 1, DtxSelectParameters)
TypedResult< qpid::framing::MessageResumeResult > messageResume(const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, exchangeDelete, 0, 3, ExchangeDeleteParameters)
Completion messageReject(const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=false)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::XaResult >, dtxEnd, 0, 4, DtxEndParameters)
BOOST_PARAMETER_MEMFUN(Completion, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters)
BOOST_PARAMETER_MEMFUN(Completion, queueDelete, 0, 4, QueueDeleteParameters)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::XaResult >, dtxCommit, 0, 3, DtxCommitParameters)
BOOST_PARAMETER_MEMFUN(Completion, messageRelease, 0, 3, MessageReleaseParameters)
BOOST_PARAMETER_MEMFUN(Completion, executionSync, 0, 1, ExecutionSyncParameters)
Completion executionException(uint16_t errorCode=0, const SequenceNumber &commandId=SequenceNumber(), uint8_t classCode=0, uint8_t commandCode=0, uint8_t fieldIndex=0, const std::string &description=std::string(), const FieldTable &errorInfo=FieldTable(), bool sync=false)
Completion messageAccept(const SequenceSet &transfers=SequenceSet(), bool sync=false)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::ExchangeBoundResult >, exchangeBound, 0, 5, ExchangeBoundParameters)
BOOST_PARAMETER_MEMFUN(Completion, txSelect, 0, 1, TxSelectParameters)
AMQP 0-10 asynchronous session API.
Completion txSelect(bool sync=false)
TypedResult< qpid::framing::XaResult > dtxCommit(const Xid &xid=Xid(), bool onePhase=false, bool sync=false)
Completion exchangeDeclare(const std::string &exchange=std::string(), const std::string &type=std::string(), const std::string &alternateExchange=std::string(), bool passive=false, bool durable=false, bool autoDelete=false, const FieldTable &arguments=FieldTable(), bool sync=false)
Completion executionSync(bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, messageAccept, 0, 2, MessageAcceptParameters)
Completion dtxForget(const Xid &xid=Xid(), bool sync=false)
Completion messageStop(const std::string &destination=std::string(), bool sync=false)
TypedResult< qpid::framing::XaResult > dtxPrepare(const Xid &xid=Xid(), bool sync=false)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::MessageAcquireResult >, messageAcquire, 0, 2, MessageAcquireParameters)
BOOST_PARAMETER_MEMFUN(Completion, executionException, 0, 8, ExecutionExceptionParameters)
QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10 & operator=(const SessionBase_0_10 &other)
BOOST_PARAMETER_MEMFUN(Completion, exchangeBind, 0, 5, ExchangeBindParameters)
Completion messageTransfer(const std::string &destination=std::string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const Message &content=Message(std::string()), bool sync=false)
Completion txRollback(bool sync=false)
Completion messageRelease(const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=false)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::MessageResumeResult >, messageResume, 0, 3, MessageResumeParameters)
BOOST_PARAMETER_MEMFUN(Completion, executionResult, 0, 3, ExecutionResultParameters)
BOOST_PARAMETER_MEMFUN(Completion, messageReject, 0, 4, MessageRejectParameters)
TypedResult< qpid::framing::XaResult > dtxStart(const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, messageSubscribe, 0, 9, MessageSubscribeParameters)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::DtxRecoverResult >, dtxRecover, 0, 1, DtxRecoverParameters)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::QueueQueryResult >, queueQuery, 0, 2, QueueQueryParameters)
Session_0_10 sync(const SessionBase_0_10 &other)
Conversion to Session_0_10 from another session type.
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::XaResult >, dtxRollback, 0, 2, DtxRollbackParameters)
Completion queueDeclare(const std::string &queue=std::string(), const std::string &alternateExchange=std::string(), bool passive=false, bool durable=false, bool exclusive=false, bool autoDelete=false, const FieldTable &arguments=FieldTable(), bool sync=false)
TypedResult< qpid::framing::MessageAcquireResult > messageAcquire(const SequenceSet &transfers=SequenceSet(), bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, messageCancel, 0, 2, MessageCancelParameters)
AMQP 0-10 session API with keyword arguments.
Completion dtxSetTimeout(const Xid &xid=Xid(), uint32_t timeout=0, bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, messageFlush, 0, 2, MessageFlushParameters)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::XaResult >, dtxStart, 0, 4, DtxStartParameters)
AsyncSession_0_10 async(const SessionBase_0_10 &other)
Conversion to AsyncSession_0_10 from another session type.
Completion exchangeDelete(const std::string &exchange=std::string(), bool ifUnused=false, bool sync=false)
Completion dtxSelect(bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, queuePurge, 0, 2, QueuePurgeParameters)
BOOST_PARAMETER_MEMFUN(Completion, messageStop, 0, 2, MessageStopParameters)
BOOST_PARAMETER_MEMFUN(Completion, messageTransfer, 0, 5, MessageTransferParameters)
BOOST_PARAMETER_MEMFUN(TypedResult< qpid::framing::DtxGetTimeoutResult >, dtxGetTimeout, 0, 2, DtxGetTimeoutParameters)
BOOST_PARAMETER_MEMFUN(Completion, queueDeclare, 0, 8, QueueDeclareParameters)
TypedResult< qpid::framing::QueueQueryResult > queueQuery(const std::string &queue=std::string(), bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, dtxForget, 0, 2, DtxForgetParameters)
BOOST_PARAMETER_MEMFUN(Completion, exchangeDeclare, 0, 8, ExchangeDeclareParameters)
Completion messageSubscribe(const std::string &queue=std::string(), const std::string &destination=std::string(), uint8_t acceptMode=0, uint8_t acquireMode=0, bool exclusive=false, const std::string &resumeId=std::string(), uint64_t resumeTtl=0, const FieldTable &arguments=FieldTable(), bool sync=false)
Completion exchangeBind(const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), const FieldTable &arguments=FieldTable(), bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, txCommit, 0, 1, TxCommitParameters)
TypedResult< qpid::framing::XaResult > dtxEnd(const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=false)
Completion messageFlow(const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=false)
Completion txCommit(bool sync=false)
TypedResult< qpid::framing::DtxRecoverResult > dtxRecover(bool sync=false)
BOOST_PARAMETER_MEMFUN(Completion, txRollback, 0, 1, TxRollbackParameters)