#include <SessionHandler.h>
Public Types | |
typedef framing::AMQP_AllProxy::Session | Peer |
Public Member Functions | |
SessionHandler (framing::FrameHandler &out, uint16_t channel) | |
void | setChannel (uint16_t ch) |
uint16_t | getChannel () const |
void | setOutHandler (framing::FrameHandler &h) |
virtual SessionState * | getState ()=0 |
virtual framing::FrameHandler * | getInHandler ()=0 |
void | sendDetach () |
void | sendCompletion () |
void | sendAttach (bool force) |
void | sendTimeout (uint32_t t) |
void | sendFlush () |
void | sendCommandPoint () |
bool | ready () const |
True if the handler is ready to send and receive. | |
void | attach (const std::string &name, bool force) |
void | attached (const std::string &name) |
void | detach (const std::string &name) |
void | detached (const std::string &name, uint8_t code) |
void | requestTimeout (uint32_t t) |
void | timeout (uint32_t t) |
void | commandPoint (const framing::SequenceNumber &id, uint64_t offset) |
void | expected (const framing::SequenceSet &commands, const framing::Array &fragments) |
void | confirmed (const framing::SequenceSet &commands, const framing::Array &fragments) |
void | completed (const framing::SequenceSet &commands, bool timelyReply) |
void | knownCompleted (const framing::SequenceSet &commands) |
void | flush (bool expected, bool confirmed, bool completed) |
void | gap (const framing::SequenceSet &commands) |
Protected Member Functions | |
virtual void | invoke (const framing::AMQMethodBody &m) |
virtual void | setState (const std::string &sessionName, bool force)=0 |
virtual void | channelException (uint16_t code, const std::string &msg)=0 |
virtual void | connectionException (uint16_t code, const std::string &msg)=0 |
virtual void | readyToSend () |
virtual void | readyToReceive () |
virtual void | handleDetach () |
virtual void | handleIn (framing::AMQFrame &) |
virtual void | handleOut (framing::AMQFrame &) |
void | checkAttached () |
void | checkName (const std::string &name) |
Protected Attributes | |
framing::ChannelHandler | channel |
Peer | peer |
bool | ignoring |
bool | sendReady |
bool | receiveReady |
A SessionHandler is associated with a channel and can be attached to a session state.