Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
AMQP 0-10 session API with keyword arguments. More...
#include <qpid/client/AsyncSession_0_10.h>
Public Member Functions | |
AsyncSession_0_10 () | |
QPID_CLIENT_INLINE_EXTERN | AsyncSession_0_10 (const SessionBase_0_10 &other) |
QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10 & | operator= (const SessionBase_0_10 &other) |
BOOST_PARAMETER_MEMFUN (Completion, executionSync, 0, 1, ExecutionSyncParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, executionResult, 0, 3, ExecutionResultParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, executionException, 0, 8, ExecutionExceptionParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageTransfer, 0, 5, MessageTransferParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageAccept, 0, 2, MessageAcceptParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageReject, 0, 4, MessageRejectParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageRelease, 0, 3, MessageReleaseParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::MessageAcquireResult >, messageAcquire, 0, 2, MessageAcquireParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::MessageResumeResult >, messageResume, 0, 3, MessageResumeParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageSubscribe, 0, 9, MessageSubscribeParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageCancel, 0, 2, MessageCancelParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageSetFlowMode, 0, 3, MessageSetFlowModeParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageFlow, 0, 4, MessageFlowParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageFlush, 0, 2, MessageFlushParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, messageStop, 0, 2, MessageStopParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, txSelect, 0, 1, TxSelectParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, txCommit, 0, 1, TxCommitParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, txRollback, 0, 1, TxRollbackParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, dtxSelect, 0, 1, DtxSelectParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxStart, 0, 4, DtxStartParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxEnd, 0, 4, DtxEndParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxCommit, 0, 3, DtxCommitParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, dtxForget, 0, 2, DtxForgetParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::DtxGetTimeoutResult >, dtxGetTimeout, 0, 2, DtxGetTimeoutParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxPrepare, 0, 2, DtxPrepareParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::DtxRecoverResult >, dtxRecover, 0, 1, DtxRecoverParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::XaResult >, dtxRollback, 0, 2, DtxRollbackParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, dtxSetTimeout, 0, 3, DtxSetTimeoutParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, exchangeDeclare, 0, 8, ExchangeDeclareParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, exchangeDelete, 0, 3, ExchangeDeleteParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::ExchangeQueryResult >, exchangeQuery, 0, 2, ExchangeQueryParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, exchangeBind, 0, 5, ExchangeBindParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, exchangeUnbind, 0, 4, ExchangeUnbindParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::ExchangeBoundResult >, exchangeBound, 0, 5, ExchangeBoundParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, queueDeclare, 0, 8, QueueDeclareParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, queueDelete, 0, 4, QueueDeleteParameters) | |
BOOST_PARAMETER_MEMFUN (Completion, queuePurge, 0, 2, QueuePurgeParameters) | |
BOOST_PARAMETER_MEMFUN (TypedResult< qpid::framing::QueueQueryResult >, queueQuery, 0, 2, QueueQueryParameters) | |
Completion | executionSync (bool sync=false) |
Completion | executionResult (const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=false) |
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 | 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 | messageAccept (const SequenceSet &transfers=SequenceSet(), bool sync=false) |
Completion | messageReject (const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=false) |
Completion | messageRelease (const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=false) |
TypedResult < qpid::framing::MessageAcquireResult > | messageAcquire (const SequenceSet &transfers=SequenceSet(), bool sync=false) |
TypedResult < qpid::framing::MessageResumeResult > | messageResume (const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=false) |
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 | messageCancel (const std::string &destination=std::string(), bool sync=false) |
Completion | messageSetFlowMode (const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=false) |
Completion | messageFlow (const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=false) |
Completion | messageFlush (const std::string &destination=std::string(), bool sync=false) |
Completion | messageStop (const std::string &destination=std::string(), bool sync=false) |
Completion | txSelect (bool sync=false) |
Completion | txCommit (bool sync=false) |
Completion | txRollback (bool sync=false) |
Completion | dtxSelect (bool sync=false) |
TypedResult < qpid::framing::XaResult > | dtxStart (const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=false) |
TypedResult < qpid::framing::XaResult > | dtxEnd (const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=false) |
TypedResult < qpid::framing::XaResult > | dtxCommit (const Xid &xid=Xid(), bool onePhase=false, bool sync=false) |
Completion | dtxForget (const Xid &xid=Xid(), bool sync=false) |
TypedResult < qpid::framing::DtxGetTimeoutResult > | dtxGetTimeout (const Xid &xid=Xid(), bool sync=false) |
TypedResult < qpid::framing::XaResult > | dtxPrepare (const Xid &xid=Xid(), bool sync=false) |
TypedResult < qpid::framing::DtxRecoverResult > | dtxRecover (bool sync=false) |
TypedResult < qpid::framing::XaResult > | dtxRollback (const Xid &xid=Xid(), bool sync=false) |
Completion | dtxSetTimeout (const Xid &xid=Xid(), uint32_t timeout=0, 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 | exchangeDelete (const std::string &exchange=std::string(), bool ifUnused=false, bool sync=false) |
TypedResult < qpid::framing::ExchangeQueryResult > | exchangeQuery (const std::string &name=std::string(), 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) |
Completion | exchangeUnbind (const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=false) |
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 | 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) |
Completion | queueDelete (const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=false) |
Completion | queuePurge (const std::string &queue=std::string(), bool sync=false) |
TypedResult < qpid::framing::QueueQueryResult > | queueQuery (const std::string &queue=std::string(), bool sync=false) |
AMQP 0-10 session API with keyword arguments.
This class provides the same set of functions as no_keyword::AsyncSession_0_10, but also allows parameters be passed using keywords. The keyword is the parameter name in the namespace "arg".
For example given the normal function "foo(int x=0, int y=0, int z=0)" you could call it in either of the following ways:
session.foo(1,2,3); // Normal no keywords session.foo(arg::z=3, arg::x=1); // Keywords and a default
The keyword functions are easy to use but their declarations are hard to read. You may find it easier to read the documentation for no_keyword::AsyncSession_0_10 which provides the same set of functions using normal non-keyword declarations.
session.messageTransfer(arg::content=message, arg::destination="amq.topic");
messageTransfer() — asynchronous
#include <qpid/client/AsyncSession.h>
for (int i=0; i<10; i++) { message.setData(message_data.str()); async(session).messageTransfer(arg::content=message, arg::destination="amq.direct"); }
session.sync();
session.exchangeBind(arg::exchange="amq.topic", arg::queue=queue, arg::bindingKey=routing_key);
session.exchangeUnBind(arg::exchange="amq.topic", arg::queue=queue, arg::bindingKey=routing_key);
if (session.exchangeBound(arg::exchange="amq.topic", arg::queue=queue, arg::bindingKey=rk)){...}
if (session.exchangeBound(arg::exchange="amq.topic", arg::queue=queue)){...}
session.exchangeDeclare(arg::exchange="my.topic", arg::type="topic");
session.exchangeDeclare(arg::exchange="xml", arg::type="xml");
session.exchangeDeclare(arg::exchange="my.topic");
session.exchangeDeclare(arg::exchange="xml", arg::ifUnused=true);
ExchangeQueryResult eqr = session.exchangeQuery(arg::exchange="my.topic");
arg::durable=true
Default: false.
If durable=true, an exchange remains active even if the server is restarted. If durable=false, an exchange is purged when a server restarts.
arg::autoDelete=true
Default: false.
If autoDelete=true, deleting the last binding for an exchange also deletes the exchange.
arg::alternatExchange="my.exchange"
Default: none.
If an alternate exchange is specified, messages that can not be delivered to any queue are sent to the alternate exchange.
session.queueDeclare(arg::queue="message_queue");
session.queueDelete(arg::queue="message_queue");
session.queuePurge(arg::queue="message_queue");
QueueQueryResult qqr = session.queueQuery(arg::queue="message_queue");
arg::durable=true
Default: false.
If durable=true, a queue remains active if the server is restarted. If durable=false, a queue and its contents are lost when a server restarts.
arg::autoDelete=true
Default: false.
If autoDelete=true, the queue is deleted when the last active Subscription to the Queue is canceled.
arg::exclusive=true
Default: false.
If exclusive=true, only the Session that created a queue can access it.
arg::alternateExchange="my.exchange"
Default: none.
If an alternate exchange is specified, messages are routed to it if (1) they are rejected by a client, or (2) they remain on the queue when it is deleted.
messageAccept() — acknowledges messages
SequenceSet tobeAccepted; toAccepted.add(msg.getId()); session.messageAccept(toBeAccepted);
SequenceSet tobeAcquired; toBeAcquired.add(msg.getId()); session.messageAcquire(toBeAcquired);
SequenceSet tobeRejected; toRejected.add(msg.getId()); session.messageReject(toBeRejected);
SequenceSet tobeReleased; toReleased.add(msg.getId()); session.messageRelease(toBeReleased);
session.txSelect();
session.txSelect();
session.txRollback();
Definition at line 189 of file AsyncSession_0_10.h.
qpid::client::AsyncSession_0_10::AsyncSession_0_10 | ( | ) | [inline] |
Reimplemented from qpid::client::no_keyword::AsyncSession_0_10.
Definition at line 555 of file AsyncSession_0_10.h.
qpid::client::AsyncSession_0_10::AsyncSession_0_10 | ( | const SessionBase_0_10 & | other | ) | [inline] |
Reimplemented from qpid::client::no_keyword::AsyncSession_0_10.
Definition at line 556 of file AsyncSession_0_10.h.
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
executionSync | , | ||
0 | , | ||
1 | , | ||
ExecutionSyncParameters | |||
) | [inline] |
Definition at line 276 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::executionSync(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
executionResult | , | ||
0 | , | ||
3 | , | ||
ExecutionResultParameters | |||
) | [inline] |
Definition at line 281 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::executionResult(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
executionException | , | ||
0 | , | ||
8 | , | ||
ExecutionExceptionParameters | |||
) | [inline] |
Definition at line 288 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::executionException(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageTransfer | , | ||
0 | , | ||
5 | , | ||
MessageTransferParameters | |||
) | [inline] |
Definition at line 300 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageTransfer(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageAccept | , | ||
0 | , | ||
2 | , | ||
MessageAcceptParameters | |||
) | [inline] |
Definition at line 309 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageAccept(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageReject | , | ||
0 | , | ||
4 | , | ||
MessageRejectParameters | |||
) | [inline] |
Definition at line 315 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageReject(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageRelease | , | ||
0 | , | ||
3 | , | ||
MessageReleaseParameters | |||
) | [inline] |
Definition at line 323 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageRelease(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::MessageAcquireResult > | , |
messageAcquire | , | ||
0 | , | ||
2 | , | ||
MessageAcquireParameters | |||
) | [inline] |
Definition at line 330 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageAcquire(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::MessageResumeResult > | , |
messageResume | , | ||
0 | , | ||
3 | , | ||
MessageResumeParameters | |||
) | [inline] |
Definition at line 336 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageResume(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageSubscribe | , | ||
0 | , | ||
9 | , | ||
MessageSubscribeParameters | |||
) | [inline] |
Definition at line 343 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageSubscribe(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageCancel | , | ||
0 | , | ||
2 | , | ||
MessageCancelParameters | |||
) | [inline] |
Definition at line 356 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageCancel(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageSetFlowMode | , | ||
0 | , | ||
3 | , | ||
MessageSetFlowModeParameters | |||
) | [inline] |
Definition at line 362 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageSetFlowMode(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageFlow | , | ||
0 | , | ||
4 | , | ||
MessageFlowParameters | |||
) | [inline] |
Definition at line 369 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageFlow(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageFlush | , | ||
0 | , | ||
2 | , | ||
MessageFlushParameters | |||
) | [inline] |
Definition at line 377 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageFlush(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
messageStop | , | ||
0 | , | ||
2 | , | ||
MessageStopParameters | |||
) | [inline] |
Definition at line 383 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::messageStop(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
txSelect | , | ||
0 | , | ||
1 | , | ||
TxSelectParameters | |||
) | [inline] |
Definition at line 389 of file AsyncSession_0_10.h.
References qpid::client::sync(), and qpid::client::no_keyword::AsyncSession_0_10::txSelect().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
txCommit | , | ||
0 | , | ||
1 | , | ||
TxCommitParameters | |||
) | [inline] |
Definition at line 394 of file AsyncSession_0_10.h.
References qpid::client::sync(), and qpid::client::no_keyword::AsyncSession_0_10::txCommit().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
txRollback | , | ||
0 | , | ||
1 | , | ||
TxRollbackParameters | |||
) | [inline] |
Definition at line 399 of file AsyncSession_0_10.h.
References qpid::client::sync(), and qpid::client::no_keyword::AsyncSession_0_10::txRollback().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
dtxSelect | , | ||
0 | , | ||
1 | , | ||
DtxSelectParameters | |||
) | [inline] |
Definition at line 404 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxSelect(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::XaResult > | , |
dtxStart | , | ||
0 | , | ||
4 | , | ||
DtxStartParameters | |||
) | [inline] |
Definition at line 409 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxStart(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::XaResult > | , |
dtxEnd | , | ||
0 | , | ||
4 | , | ||
DtxEndParameters | |||
) | [inline] |
Definition at line 417 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxEnd(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::XaResult > | , |
dtxCommit | , | ||
0 | , | ||
3 | , | ||
DtxCommitParameters | |||
) | [inline] |
Definition at line 425 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxCommit(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
dtxForget | , | ||
0 | , | ||
2 | , | ||
DtxForgetParameters | |||
) | [inline] |
Definition at line 432 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxForget(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::DtxGetTimeoutResult > | , |
dtxGetTimeout | , | ||
0 | , | ||
2 | , | ||
DtxGetTimeoutParameters | |||
) | [inline] |
Definition at line 438 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxGetTimeout(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::XaResult > | , |
dtxPrepare | , | ||
0 | , | ||
2 | , | ||
DtxPrepareParameters | |||
) | [inline] |
Definition at line 444 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxPrepare(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::DtxRecoverResult > | , |
dtxRecover | , | ||
0 | , | ||
1 | , | ||
DtxRecoverParameters | |||
) | [inline] |
Definition at line 450 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxRecover(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::XaResult > | , |
dtxRollback | , | ||
0 | , | ||
2 | , | ||
DtxRollbackParameters | |||
) | [inline] |
Definition at line 455 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxRollback(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
dtxSetTimeout | , | ||
0 | , | ||
3 | , | ||
DtxSetTimeoutParameters | |||
) | [inline] |
Definition at line 461 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::dtxSetTimeout(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
exchangeDeclare | , | ||
0 | , | ||
8 | , | ||
ExchangeDeclareParameters | |||
) | [inline] |
Definition at line 468 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::exchangeDeclare(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
exchangeDelete | , | ||
0 | , | ||
3 | , | ||
ExchangeDeleteParameters | |||
) | [inline] |
Definition at line 480 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::exchangeDelete(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::ExchangeQueryResult > | , |
exchangeQuery | , | ||
0 | , | ||
2 | , | ||
ExchangeQueryParameters | |||
) | [inline] |
Definition at line 487 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::exchangeQuery(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
exchangeBind | , | ||
0 | , | ||
5 | , | ||
ExchangeBindParameters | |||
) | [inline] |
Definition at line 493 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::exchangeBind(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
exchangeUnbind | , | ||
0 | , | ||
4 | , | ||
ExchangeUnbindParameters | |||
) | [inline] |
Definition at line 502 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::exchangeUnbind(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::ExchangeBoundResult > | , |
exchangeBound | , | ||
0 | , | ||
5 | , | ||
ExchangeBoundParameters | |||
) | [inline] |
Definition at line 510 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::exchangeBound(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
queueDeclare | , | ||
0 | , | ||
8 | , | ||
QueueDeclareParameters | |||
) | [inline] |
Definition at line 519 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::queueDeclare(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
queueDelete | , | ||
0 | , | ||
4 | , | ||
QueueDeleteParameters | |||
) | [inline] |
Definition at line 531 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::queueDelete(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | Completion | , |
queuePurge | , | ||
0 | , | ||
2 | , | ||
QueuePurgeParameters | |||
) | [inline] |
Definition at line 539 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::queuePurge(), and qpid::client::sync().
qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN | ( | TypedResult< qpid::framing::QueueQueryResult > | , |
queueQuery | , | ||
0 | , | ||
2 | , | ||
QueueQueryParameters | |||
) | [inline] |
Definition at line 545 of file AsyncSession_0_10.h.
References qpid::client::no_keyword::AsyncSession_0_10::queueQuery(), and qpid::client::sync().
TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxCommit | ( | const Xid & | xid = Xid() , |
bool | onePhase = false , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxEnd | ( | const Xid & | xid = Xid() , |
bool | fail = false , |
||
bool | suspend = false , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::dtxForget | ( | const Xid & | xid = Xid() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::DtxGetTimeoutResult> qpid::client::no_keyword::AsyncSession_0_10::dtxGetTimeout | ( | const Xid & | xid = Xid() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxPrepare | ( | const Xid & | xid = Xid() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::DtxRecoverResult> qpid::client::no_keyword::AsyncSession_0_10::dtxRecover | ( | bool | sync = false | ) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxRollback | ( | const Xid & | xid = Xid() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::dtxSelect | ( | bool | sync = false | ) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::dtxSetTimeout | ( | const Xid & | xid = Xid() , |
uint32_t | timeout = 0 , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxStart | ( | const Xid & | xid = Xid() , |
bool | join = false , |
||
bool | resume = false , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::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 |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::ExchangeBoundResult> qpid::client::no_keyword::AsyncSession_0_10::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 |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::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 |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::exchangeDelete | ( | const std::string & | exchange = std::string() , |
bool | ifUnused = false , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::ExchangeQueryResult> qpid::client::no_keyword::AsyncSession_0_10::exchangeQuery | ( | const std::string & | name = std::string() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::exchangeUnbind | ( | const std::string & | queue = std::string() , |
const std::string & | exchange = std::string() , |
||
const std::string & | bindingKey = std::string() , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::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 |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::executionResult | ( | const SequenceNumber & | commandId = SequenceNumber() , |
const std::string & | value = std::string() , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::executionSync | ( | bool | sync = false | ) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageAccept | ( | const SequenceSet & | transfers = SequenceSet() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::MessageAcquireResult> qpid::client::no_keyword::AsyncSession_0_10::messageAcquire | ( | const SequenceSet & | transfers = SequenceSet() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageCancel | ( | const std::string & | destination = std::string() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageFlow | ( | const std::string & | destination = std::string() , |
uint8_t | unit = 0 , |
||
uint32_t | value = 0 , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageFlush | ( | const std::string & | destination = std::string() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageReject | ( | const SequenceSet & | transfers = SequenceSet() , |
uint16_t | code = 0 , |
||
const std::string & | text = std::string() , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageRelease | ( | const SequenceSet & | transfers = SequenceSet() , |
bool | setRedelivered = false , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::MessageResumeResult> qpid::client::no_keyword::AsyncSession_0_10::messageResume | ( | const std::string & | destination = std::string() , |
const std::string & | resumeId = std::string() , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageSetFlowMode | ( | const std::string & | destination = std::string() , |
uint8_t | flowMode = 0 , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageStop | ( | const std::string & | destination = std::string() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::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 |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::messageTransfer | ( | const std::string & | destination = std::string() , |
uint8_t | acceptMode = 1 , |
||
uint8_t | acquireMode = 0 , |
||
const Message & | content = Message(std::string()) , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
AsyncSession_0_10 & qpid::client::AsyncSession_0_10::operator= | ( | const SessionBase_0_10 & | other | ) | [inline] |
Reimplemented from qpid::client::no_keyword::AsyncSession_0_10.
Definition at line 559 of file AsyncSession_0_10.h.
Completion qpid::client::no_keyword::AsyncSession_0_10::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 |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::queueDelete | ( | const std::string & | queue = std::string() , |
bool | ifUnused = false , |
||
bool | ifEmpty = false , |
||
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::queuePurge | ( | const std::string & | queue = std::string() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
TypedResult<qpid::framing::QueueQueryResult> qpid::client::no_keyword::AsyncSession_0_10::queueQuery | ( | const std::string & | queue = std::string() , |
bool | sync = false |
||
) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::txCommit | ( | bool | sync = false | ) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::txRollback | ( | bool | sync = false | ) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().
Completion qpid::client::no_keyword::AsyncSession_0_10::txSelect | ( | bool | sync = false | ) | [inherited] |
Referenced by BOOST_PARAMETER_MEMFUN().