#include <SessionBase_0_10.h>
Public Types | |
typedef framing::TransferContent | DefaultContent |
Public Member Functions | |
framing::FrameSet::shared_ptr | get () |
Get the next message frame-set from the session. | |
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. | |
Execution & | getExecution () |
void | flush () |
void | markCompleted (const framing::SequenceNumber &id, bool cumulative, bool notifyPeer) |
void | sendCompletion () |
Protected Attributes | |
boost::shared_ptr< SessionImpl > | impl |
Subclasses provide the AMQP commands for a given version of the protocol.
Definition at line 62 of file SessionBase_0_10.h.
framing::FrameSet::shared_ptr qpid::client::SessionBase_0_10::get | ( | ) |
Get the next message frame-set from the session.
void qpid::client::SessionBase_0_10::close | ( | ) |
Close the session.
A session is automatically closed when all handles to it are destroyed.
void qpid::client::SessionBase_0_10::sync | ( | ) |
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.
uint32_t qpid::client::SessionBase_0_10::timeout | ( | uint32_t | seconds | ) |
Set the timeout for this session.