1 #ifndef QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_0_10_H
2 #define QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_0_10_H
30 #include "qpid/client/SessionBase_0_10.h"
31 #include "qpid/client/ClientImportExport.h"
35 namespace no_keyword {
41 public SessionBase_0_10
47 QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10&
operator=(
const SessionBase_0_10& other);
51 QPID_CLIENT_EXTERN Completion
executionResult(
const SequenceNumber& commandId=SequenceNumber(),
const std::string& value=std::string(),
bool sync=
false);
53 QPID_CLIENT_EXTERN 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);
55 QPID_CLIENT_EXTERN 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);
57 QPID_CLIENT_EXTERN Completion
messageAccept(
const SequenceSet& transfers=SequenceSet(),
bool sync=
false);
59 QPID_CLIENT_EXTERN Completion
messageReject(
const SequenceSet& transfers=SequenceSet(),
uint16_t code=0,
const std::string& text=std::string(),
bool sync=
false);
61 QPID_CLIENT_EXTERN Completion
messageRelease(
const SequenceSet& transfers=SequenceSet(),
bool setRedelivered=
false,
bool sync=
false);
63 QPID_CLIENT_EXTERN TypedResult<qpid::framing::MessageAcquireResult>
messageAcquire(
const SequenceSet& transfers=SequenceSet(),
bool sync=
false);
65 QPID_CLIENT_EXTERN TypedResult<qpid::framing::MessageResumeResult>
messageResume(
const std::string& destination=std::string(),
const std::string& resumeId=std::string(),
bool sync=
false);
67 QPID_CLIENT_EXTERN 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);
69 QPID_CLIENT_EXTERN Completion
messageCancel(
const std::string& destination=std::string(),
bool sync=
false);
75 QPID_CLIENT_EXTERN Completion
messageFlush(
const std::string& destination=std::string(),
bool sync=
false);
77 QPID_CLIENT_EXTERN Completion
messageStop(
const std::string& destination=std::string(),
bool sync=
false);
87 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult>
dtxStart(
const Xid& xid=Xid(),
bool join=
false,
bool resume=
false,
bool sync=
false);
89 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult>
dtxEnd(
const Xid& xid=Xid(),
bool fail=
false,
bool suspend=
false,
bool sync=
false);
91 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult>
dtxCommit(
const Xid& xid=Xid(),
bool onePhase=
false,
bool sync=
false);
93 QPID_CLIENT_EXTERN Completion
dtxForget(
const Xid& xid=Xid(),
bool sync=
false);
95 QPID_CLIENT_EXTERN TypedResult<qpid::framing::DtxGetTimeoutResult>
dtxGetTimeout(
const Xid& xid=Xid(),
bool sync=
false);
97 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult>
dtxPrepare(
const Xid& xid=Xid(),
bool sync=
false);
99 QPID_CLIENT_EXTERN TypedResult<qpid::framing::DtxRecoverResult>
dtxRecover(
bool sync=
false);
101 QPID_CLIENT_EXTERN TypedResult<qpid::framing::XaResult>
dtxRollback(
const Xid& xid=Xid(),
bool sync=
false);
105 QPID_CLIENT_EXTERN 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);
107 QPID_CLIENT_EXTERN Completion
exchangeDelete(
const std::string& exchange=std::string(),
bool ifUnused=
false,
bool sync=
false);
109 QPID_CLIENT_EXTERN TypedResult<qpid::framing::ExchangeQueryResult>
exchangeQuery(
const std::string& name=std::string(),
bool sync=
false);
111 QPID_CLIENT_EXTERN 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);
113 QPID_CLIENT_EXTERN Completion
exchangeUnbind(
const std::string& queue=std::string(),
const std::string& exchange=std::string(),
const std::string& bindingKey=std::string(),
bool sync=
false);
115 QPID_CLIENT_EXTERN 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);
117 QPID_CLIENT_EXTERN 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);
119 QPID_CLIENT_EXTERN Completion
queueDelete(
const std::string& queue=std::string(),
bool ifUnused=
false,
bool ifEmpty=
false,
bool sync=
false);
121 QPID_CLIENT_EXTERN Completion
queuePurge(
const std::string& queue=std::string(),
bool sync=
false);
123 QPID_CLIENT_EXTERN TypedResult<qpid::framing::QueueQueryResult>
queueQuery(
const std::string& queue=std::string(),
bool sync=
false);
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)
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)
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)
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::MessageResumeResult > messageResume(const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=false)
Completion messageReject(const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=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 messageAccept(const SequenceSet &transfers=SequenceSet(), bool sync=false)
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)
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)
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)
QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10 & operator=(const SessionBase_0_10 &other)
Completion txRollback(bool sync=false)
Completion messageRelease(const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=false)
TypedResult< qpid::framing::XaResult > dtxStart(const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=false)
Session_0_10 sync(const SessionBase_0_10 &other)
Conversion to Session_0_10 from another session type.
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)
Completion dtxSetTimeout(const Xid &xid=Xid(), uint32_t timeout=0, bool sync=false)
Completion exchangeDelete(const std::string &exchange=std::string(), bool ifUnused=false, bool sync=false)
Completion dtxSelect(bool sync=false)
TypedResult< qpid::framing::QueueQueryResult > queueQuery(const std::string &queue=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 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)
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)