| Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
AMQP 0-10 asynchronous session API. More...
#include <qpid/client/no_keyword/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) |
| 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 asynchronous session API.
Definition at line 40 of file AsyncSession_0_10.h.
| qpid::client::no_keyword::AsyncSession_0_10::AsyncSession_0_10 | ( | ) |
| QPID_CLIENT_INLINE_EXTERN qpid::client::no_keyword::AsyncSession_0_10::AsyncSession_0_10 | ( | const SessionBase_0_10 & | other | ) |
| TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxCommit | ( | const Xid & | xid = Xid(), |
| bool | onePhase = false, |
||
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::dtxForget | ( | const Xid & | xid = Xid(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| TypedResult<qpid::framing::DtxGetTimeoutResult> qpid::client::no_keyword::AsyncSession_0_10::dtxGetTimeout | ( | const Xid & | xid = Xid(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxPrepare | ( | const Xid & | xid = Xid(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| TypedResult<qpid::framing::DtxRecoverResult> qpid::client::no_keyword::AsyncSession_0_10::dtxRecover | ( | bool | sync = false | ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| TypedResult<qpid::framing::XaResult> qpid::client::no_keyword::AsyncSession_0_10::dtxRollback | ( | const Xid & | xid = Xid(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::dtxSelect | ( | bool | sync = false | ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::dtxSetTimeout | ( | const Xid & | xid = Xid(), |
| uint32_t | timeout = 0, |
||
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::exchangeDelete | ( | const std::string & | exchange = std::string(), |
| bool | ifUnused = false, |
||
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| TypedResult<qpid::framing::ExchangeQueryResult> qpid::client::no_keyword::AsyncSession_0_10::exchangeQuery | ( | const std::string & | name = std::string(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::executionSync | ( | bool | sync = false | ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::messageAccept | ( | const SequenceSet & | transfers = SequenceSet(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| TypedResult<qpid::framing::MessageAcquireResult> qpid::client::no_keyword::AsyncSession_0_10::messageAcquire | ( | const SequenceSet & | transfers = SequenceSet(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::messageCancel | ( | const std::string & | destination = std::string(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::messageFlush | ( | const std::string & | destination = std::string(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::messageRelease | ( | const SequenceSet & | transfers = SequenceSet(), |
| bool | setRedelivered = false, |
||
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::messageStop | ( | const std::string & | destination = std::string(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10& qpid::client::no_keyword::AsyncSession_0_10::operator= | ( | const SessionBase_0_10 & | other | ) |
| 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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::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 |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::queuePurge | ( | const std::string & | queue = std::string(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| TypedResult<qpid::framing::QueueQueryResult> qpid::client::no_keyword::AsyncSession_0_10::queueQuery | ( | const std::string & | queue = std::string(), |
| bool | sync = false |
||
| ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::txCommit | ( | bool | sync = false | ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::txRollback | ( | bool | sync = false | ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
| Completion qpid::client::no_keyword::AsyncSession_0_10::txSelect | ( | bool | sync = false | ) |
Referenced by qpid::client::AsyncSession_0_10::BOOST_PARAMETER_MEMFUN().
1.8.14