Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
AMQP 0-10 synchronous session API. More...
#include <qpid/client/no_keyword/Session_0_10.h>
Public Member Functions | |
Session_0_10 () | |
QPID_CLIENT_INLINE_EXTERN | Session_0_10 (const SessionBase_0_10 &other) |
QPID_CLIENT_INLINE_EXTERN Session_0_10 & | operator= (const SessionBase_0_10 &other) |
void | executionSync (bool sync=true) |
void | executionResult (const SequenceNumber &commandId=SequenceNumber(), const std::string &value=std::string(), bool sync=true) |
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) |
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 | messageAccept (const SequenceSet &transfers=SequenceSet(), bool sync=true) |
void | messageReject (const SequenceSet &transfers=SequenceSet(), uint16_t code=0, const std::string &text=std::string(), bool sync=true) |
void | messageRelease (const SequenceSet &transfers=SequenceSet(), bool setRedelivered=false, bool sync=true) |
qpid::framing::MessageAcquireResult | messageAcquire (const SequenceSet &transfers=SequenceSet(), bool sync=true) |
qpid::framing::MessageResumeResult | messageResume (const std::string &destination=std::string(), const std::string &resumeId=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 | messageCancel (const std::string &destination=std::string(), bool sync=true) |
void | messageSetFlowMode (const std::string &destination=std::string(), uint8_t flowMode=0, bool sync=true) |
void | messageFlow (const std::string &destination=std::string(), uint8_t unit=0, uint32_t value=0, bool sync=true) |
void | messageFlush (const std::string &destination=std::string(), bool sync=true) |
void | messageStop (const std::string &destination=std::string(), bool sync=true) |
void | txSelect (bool sync=true) |
void | txCommit (bool sync=true) |
void | txRollback (bool sync=true) |
void | dtxSelect (bool sync=true) |
qpid::framing::XaResult | dtxStart (const Xid &xid=Xid(), bool join=false, bool resume=false, bool sync=true) |
qpid::framing::XaResult | dtxEnd (const Xid &xid=Xid(), bool fail=false, bool suspend=false, bool sync=true) |
qpid::framing::XaResult | dtxCommit (const Xid &xid=Xid(), bool onePhase=false, bool sync=true) |
void | dtxForget (const Xid &xid=Xid(), bool sync=true) |
qpid::framing::DtxGetTimeoutResult | dtxGetTimeout (const Xid &xid=Xid(), bool sync=true) |
qpid::framing::XaResult | dtxPrepare (const Xid &xid=Xid(), bool sync=true) |
qpid::framing::DtxRecoverResult | dtxRecover (bool sync=true) |
qpid::framing::XaResult | dtxRollback (const Xid &xid=Xid(), bool sync=true) |
void | dtxSetTimeout (const Xid &xid=Xid(), uint32_t timeout=0, bool sync=true) |
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) |
void | exchangeDelete (const std::string &exchange=std::string(), bool ifUnused=false, bool sync=true) |
qpid::framing::ExchangeQueryResult | exchangeQuery (const std::string &name=std::string(), 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) |
void | exchangeUnbind (const std::string &queue=std::string(), const std::string &exchange=std::string(), const std::string &bindingKey=std::string(), bool sync=true) |
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) |
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 | queueDelete (const std::string &queue=std::string(), bool ifUnused=false, bool ifEmpty=false, bool sync=true) |
void | queuePurge (const std::string &queue=std::string(), bool sync=true) |
qpid::framing::QueueQueryResult | queueQuery (const std::string &queue=std::string(), bool sync=true) |
SessionId | getId () const |
Get the session ID. | |
void | close () |
Close the session. | |
void | sync () |
Synchronize the session: sync() waits until all commands issued on this session so far have been completed by the broker. | |
uint32_t | timeout (uint32_t seconds) |
Set the timeout for this session. | |
void | suspend () |
Suspend the session - detach it from its connection. | |
void | resume (Connection) |
Resume a suspended session with a new connection. | |
uint16_t | getChannel () const |
Get the channel associated with this session. | |
void | flush () |
void | markCompleted (const framing::SequenceSet &ids, bool notifyPeer) |
void | markCompleted (const framing::SequenceNumber &id, bool cumulative, bool notifyPeer) |
void | sendCompletion () |
bool | isValid () const |
Connection | getConnection () |
Protected Attributes | |
boost::shared_ptr< SessionImpl > | impl |
AMQP 0-10 synchronous session API.
Definition at line 40 of file Session_0_10.h.
qpid::client::no_keyword::Session_0_10::Session_0_10 | ( | ) |
Reimplemented in qpid::client::Session_0_10.
QPID_CLIENT_INLINE_EXTERN qpid::client::no_keyword::Session_0_10::Session_0_10 | ( | const SessionBase_0_10 & | other | ) |
Reimplemented in qpid::client::Session_0_10.
|
inherited |
Close the session.
A session is automatically closed when all handles to it are destroyed.
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxCommit | ( | const Xid & | xid = Xid() , |
bool | onePhase = false , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxEnd | ( | const Xid & | xid = Xid() , |
bool | fail = false , |
||
bool | suspend = false , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::dtxForget | ( | const Xid & | xid = Xid() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::DtxGetTimeoutResult qpid::client::no_keyword::Session_0_10::dtxGetTimeout | ( | const Xid & | xid = Xid() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxPrepare | ( | const Xid & | xid = Xid() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::DtxRecoverResult qpid::client::no_keyword::Session_0_10::dtxRecover | ( | bool | sync = true | ) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxRollback | ( | const Xid & | xid = Xid() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::dtxSelect | ( | bool | sync = true | ) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::dtxSetTimeout | ( | const Xid & | xid = Xid() , |
uint32_t | timeout = 0 , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::XaResult qpid::client::no_keyword::Session_0_10::dtxStart | ( | const Xid & | xid = Xid() , |
bool | join = false , |
||
bool | resume = false , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_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 = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::ExchangeBoundResult qpid::client::no_keyword::Session_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 = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_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 = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::exchangeDelete | ( | const std::string & | exchange = std::string() , |
bool | ifUnused = false , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::ExchangeQueryResult qpid::client::no_keyword::Session_0_10::exchangeQuery | ( | const std::string & | name = std::string() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::exchangeUnbind | ( | const std::string & | queue = std::string() , |
const std::string & | exchange = std::string() , |
||
const std::string & | bindingKey = std::string() , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_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 = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::executionResult | ( | const SequenceNumber & | commandId = SequenceNumber() , |
const std::string & | value = std::string() , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::executionSync | ( | bool | sync = true | ) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
|
inherited |
|
inherited |
Get the channel associated with this session.
|
inherited |
|
inherited |
Get the session ID.
|
inherited |
|
inherited |
|
inherited |
void qpid::client::no_keyword::Session_0_10::messageAccept | ( | const SequenceSet & | transfers = SequenceSet() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::MessageAcquireResult qpid::client::no_keyword::Session_0_10::messageAcquire | ( | const SequenceSet & | transfers = SequenceSet() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::messageCancel | ( | const std::string & | destination = std::string() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::messageFlow | ( | const std::string & | destination = std::string() , |
uint8_t | unit = 0 , |
||
uint32_t | value = 0 , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::messageFlush | ( | const std::string & | destination = std::string() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::messageReject | ( | const SequenceSet & | transfers = SequenceSet() , |
uint16_t | code = 0 , |
||
const std::string & | text = std::string() , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::messageRelease | ( | const SequenceSet & | transfers = SequenceSet() , |
bool | setRedelivered = false , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::MessageResumeResult qpid::client::no_keyword::Session_0_10::messageResume | ( | const std::string & | destination = std::string() , |
const std::string & | resumeId = std::string() , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::messageSetFlowMode | ( | const std::string & | destination = std::string() , |
uint8_t | flowMode = 0 , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::messageStop | ( | const std::string & | destination = std::string() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_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 = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_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 = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
QPID_CLIENT_INLINE_EXTERN Session_0_10& qpid::client::no_keyword::Session_0_10::operator= | ( | const SessionBase_0_10 & | other | ) |
Reimplemented in qpid::client::Session_0_10.
void qpid::client::no_keyword::Session_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 = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::queueDelete | ( | const std::string & | queue = std::string() , |
bool | ifUnused = false , |
||
bool | ifEmpty = false , |
||
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::queuePurge | ( | const std::string & | queue = std::string() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
qpid::framing::QueueQueryResult qpid::client::no_keyword::Session_0_10::queueQuery | ( | const std::string & | queue = std::string() , |
bool | sync = true |
||
) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
|
inherited |
Resume a suspended session with a new connection.
|
inherited |
|
inherited |
Suspend the session - detach it from its connection.
|
inherited |
Synchronize the session: sync() waits until all commands issued on this session so far have been completed by the broker.
Note sync() is always synchronous, even on an AsyncSession object because that's almost always what you want. You can call AsyncSession::executionSync() directly in the unusual event that you want to do an asynchronous sync.
Set the timeout for this session.
void qpid::client::no_keyword::Session_0_10::txCommit | ( | bool | sync = true | ) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::txRollback | ( | bool | sync = true | ) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
void qpid::client::no_keyword::Session_0_10::txSelect | ( | bool | sync = true | ) |
Referenced by qpid::client::Session_0_10::BOOST_PARAMETER_MEMFUN().
|
protectedinherited |
Definition at line 103 of file SessionBase_0_10.h.
Referenced by qpid::client::AsyncSession_0_10::operator=(), and qpid::client::Session_0_10::operator=().