1 #ifndef QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_0_10_H
2 #define QPID_CLIENT_NO_KEYWORD_ASYNCSESSION_0_10_H
35 namespace no_keyword {
void suspend()
Suspend the session - detach it from its connection.
Completion dtxSetTimeout(const Xid &xid=Xid(), uint32_t timeout=0, bool sync=false)
TypedResult< qpid::framing::QueueQueryResult > queueQuery(const std::string &queue=std::string(), bool sync=false)
void resume(Connection)
Resume a suspended session with a new connection.
4-byte sequence number that 'wraps around'.
Completion txSelect(bool sync=false)
TypedResult< qpid::framing::MessageAcquireResult > messageAcquire(const SequenceSet &transfers=SequenceSet(), 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)
Base class for handles to an AMQP session.
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 > dtxPrepare(const Xid &xid=Xid(), bool sync=false)
Completion dtxSelect(bool sync=false)
#define QPID_CLIENT_INLINE_EXTERN
Completion messageFlow(const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=false)
TypedResult< qpid::framing::XaResult > dtxCommit(const Xid &xid=Xid(), bool onePhase=false, bool sync=false)
Completion messageStop(const std::string &destination=std::string(), bool sync=false)
Completion executionResult(const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=false)
TypedResult< qpid::framing::DtxRecoverResult > dtxRecover(bool sync=false)
A message sent to or received from the broker.
Completion txRollback(bool sync=false)
Completion messageFlush(const std::string &destination=std::string(), bool sync=false)
Completion queueDelete(const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=false)
Asynchronous commands that do not return a result will return a Completion.
Completion exchangeDelete(const std::string &exchange=std::string(), bool ifUnused=false, bool sync=false)
uint32_t timeout(uint32_t seconds)
Set the timeout for this session.
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)
TypedResult< qpid::framing::XaResult > dtxEnd(const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=false)
A set of name-value pairs.
Completion messageReject(const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=false)
#define QPID_CLIENT_EXTERN
Completion txCommit(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 messageSetFlowMode(const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=false)
Completion dtxForget(const Xid &xid=Xid(), bool sync=false)
TypedResult< qpid::framing::ExchangeQueryResult > exchangeQuery(const std::string &name=std::string(), bool sync=false)
TypedResult< qpid::framing::XaResult > dtxRollback(const Xid &xid=Xid(), 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)
TypedResult< qpid::framing::DtxGetTimeoutResult > dtxGetTimeout(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)
Completion exchangeUnbind(const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=false)
void sync()
Synchronize the session: sync() waits until all commands issued on this session so far have been comp...
TypedResult< qpid::framing::MessageResumeResult > messageResume(const std::string &destination=std::string(), const std::string &resumeId=std::string(), bool sync=false)
Completion messageRelease(const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=false)
Completion queuePurge(const std::string &queue=std::string(), bool sync=false)
TypedResult< qpid::framing::XaResult > dtxStart(const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=false)
QPID_CLIENT_INLINE_EXTERN AsyncSession_0_10 & operator=(const SessionBase_0_10 &other)
AMQP 0-10 asynchronous session API.
Returned by asynchronous commands that return a result.
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)