1 #ifndef QPID_CLIENT_SESSION_0_10_H
2 #define QPID_CLIENT_SESSION_0_10_H
32 #include "qpid/client/ClientImportExport.h"
195 QPID_CLIENT_INLINE_EXTERN
Session_0_10(
const SessionBase_0_10& other);
196 QPID_CLIENT_INLINE_EXTERN Session_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()],
void queuePurge(const std::string &queue=std::string(), bool sync=true)
qpid::framing::MessageAcquireResult messageAcquire(const SequenceSet &transfers=SequenceSet(), bool sync=true)
void messageAccept(const SequenceSet &transfers=SequenceSet(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, queueDelete, 0, 4, QueueDeleteParameters)
void messageTransfer(const std::string &destination=std::string(), uint8_t acceptMode=1, uint8_t acquireMode=0, const Message &content=Message(std::string()), bool sync=true)
void messageReject(const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, messageTransfer, 0, 5, MessageTransferParameters)
BOOST_PARAMETER_MEMFUN(void, messageFlush, 0, 2, MessageFlushParameters)
void dtxForget(const Xid &xid=Xid(), bool sync=true)
void messageFlush(const std::string &destination=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::DtxGetTimeoutResult, dtxGetTimeout, 0, 2, DtxGetTimeoutParameters)
AMQP 0-10 synchronous session API.
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxPrepare, 0, 2, DtxPrepareParameters)
qpid::framing::XaResult dtxRollback(const Xid &xid=Xid(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, messageReject, 0, 4, MessageRejectParameters)
QPID_CLIENT_INLINE_EXTERN Session_0_10 & operator=(const SessionBase_0_10 &other)
BOOST_PARAMETER_MEMFUN(void, txCommit, 0, 1, TxCommitParameters)
BOOST_PARAMETER_MEMFUN(void, queueDeclare, 0, 8, QueueDeclareParameters)
qpid::framing::ExchangeQueryResult exchangeQuery(const std::string &name=std::string(), bool sync=true)
void 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=true)
void exchangeUnbind(const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=true)
void executionResult(const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxRollback, 0, 2, DtxRollbackParameters)
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=true)
BOOST_PARAMETER_MEMFUN(void, messageSubscribe, 0, 9, MessageSubscribeParameters)
void txCommit(bool sync=true)
BOOST_PARAMETER_MEMFUN(void, exchangeDelete, 0, 3, ExchangeDeleteParameters)
BOOST_PARAMETER_MEMFUN(qpid::framing::QueueQueryResult, queueQuery, 0, 2, QueueQueryParameters)
BOOST_PARAMETER_MEMFUN(void, messageCancel, 0, 2, MessageCancelParameters)
BOOST_PARAMETER_MEMFUN(void, messageStop, 0, 2, MessageStopParameters)
void txSelect(bool sync=true)
AMQP 0-10 session API with keyword arguments.
qpid::framing::XaResult dtxPrepare(const Xid &xid=Xid(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, exchangeUnbind, 0, 4, ExchangeUnbindParameters)
void txRollback(bool sync=true)
BOOST_PARAMETER_MEMFUN(void, txSelect, 0, 1, TxSelectParameters)
qpid::framing::XaResult dtxEnd(const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=true)
qpid::framing::MessageResumeResult messageResume(const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::MessageAcquireResult, messageAcquire, 0, 2, MessageAcquireParameters)
void messageFlow(const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxCommit, 0, 3, DtxCommitParameters)
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxStart, 0, 4, DtxStartParameters)
qpid::framing::XaResult dtxCommit(const Xid &xid=Xid(), bool onePhase=false, bool sync=true)
void exchangeDelete(const std::string &exchange=std::string(), bool ifUnused=false, bool sync=true)
void executionSync(bool sync=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::DtxRecoverResult, dtxRecover, 0, 1, DtxRecoverParameters)
void 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=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::ExchangeBoundResult, exchangeBound, 0, 5, ExchangeBoundParameters)
void 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=true)
void 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=true)
BOOST_PARAMETER_MEMFUN(qpid::framing::XaResult, dtxEnd, 0, 4, DtxEndParameters)
BOOST_PARAMETER_MEMFUN(void, messageAccept, 0, 2, MessageAcceptParameters)
BOOST_PARAMETER_MEMFUN(void, executionSync, 0, 1, ExecutionSyncParameters)
BOOST_PARAMETER_MEMFUN(void, exchangeDeclare, 0, 8, ExchangeDeclareParameters)
BOOST_PARAMETER_MEMFUN(void, dtxSelect, 0, 1, DtxSelectParameters)
BOOST_PARAMETER_MEMFUN(void, txRollback, 0, 1, TxRollbackParameters)
BOOST_PARAMETER_MEMFUN(void, exchangeBind, 0, 5, ExchangeBindParameters)
BOOST_PARAMETER_MEMFUN(void, messageFlow, 0, 4, MessageFlowParameters)
Session_0_10 sync(const SessionBase_0_10 &other)
Conversion to Session_0_10 from another session type.
BOOST_PARAMETER_MEMFUN(qpid::framing::MessageResumeResult, messageResume, 0, 3, MessageResumeParameters)
void messageCancel(const std::string &destination=std::string(), bool sync=true)
void messageRelease(const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=true)
qpid::framing::DtxGetTimeoutResult dtxGetTimeout(const Xid &xid=Xid(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, queuePurge, 0, 2, QueuePurgeParameters)
BOOST_PARAMETER_MEMFUN(void, messageRelease, 0, 3, MessageReleaseParameters)
void queueDelete(const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=true)
BOOST_PARAMETER_MEMFUN(void, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters)
void dtxSelect(bool sync=true)
void messageStop(const std::string &destination=std::string(), bool sync=true)
BOOST_PARAMETER_MEMFUN(void, executionException, 0, 8, ExecutionExceptionParameters)
BOOST_PARAMETER_MEMFUN(void, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters)
BOOST_PARAMETER_MEMFUN(qpid::framing::ExchangeQueryResult, exchangeQuery, 0, 2, ExchangeQueryParameters)
void 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=true)
qpid::framing::XaResult dtxStart(const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=true)
qpid::framing::QueueQueryResult queueQuery(const std::string &queue=std::string(), bool sync=true)
void messageSetFlowMode(const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=true)
void dtxSetTimeout(const Xid &xid=Xid(), uint32_t timeout=0, bool sync=true)
qpid::framing::DtxRecoverResult dtxRecover(bool sync=true)
BOOST_PARAMETER_MEMFUN(void, dtxForget, 0, 2, DtxForgetParameters)
BOOST_PARAMETER_MEMFUN(void, executionResult, 0, 3, ExecutionResultParameters)