#include <SessionState.h>
Public Member Functions | |
bool | isAttached () const |
void | detach () |
void | attach (SessionHandler &handler) |
SessionHandler * | getHandler () |
framing::AMQP_ClientProxy & | getProxy () |
ConnectionState & | getConnection () |
bool | isLocal (const ConnectionToken *t) const |
uint32_t | getTimeout () const |
void | setTimeout (uint32_t t) |
Broker & | getBroker () |
framing::ProtocolVersion | getVersion () const |
void | activateOutput () |
OutputControl. | |
void | handle (framing::AMQFrame &frame) |
void | complete (const framing::SequenceSet &ranges) |
void | sendCompletion () |
DeliveryId | deliver (QueuedMessage &msg, DeliveryToken::shared_ptr token) |
management::ManagementObject::shared_ptr | GetManagementObject (void) const |
management::Manageable::status_t | ManagementMethod (uint32_t methodId, management::Args &args) |
SessionState (SessionManager *, SessionHandler *out, uint32_t timeout, uint32_t ackInterval, std::string &name) | |
Public Attributes | |
framing::SequenceSet | completed |
framing::SequenceSet | knownCompleted |
framing::SequenceNumber | nextIn |
framing::SequenceNumber | nextOut |
framing::AMQP_ClientProxy& qpid::broker::SessionState::getProxy | ( | ) |
ConnectionState& qpid::broker::SessionState::getConnection | ( | ) |