#include <ChannelAdapter.h>
Inheritance diagram for qpid::framing::ChannelAdapter:
Public Member Functions | |
ChannelAdapter (ChannelId id_=0, OutputHandler *out_=0, ProtocolVersion ver=ProtocolVersion()) | |
void | init (ChannelId, OutputHandler &, ProtocolVersion) |
Initialize the channel adapter. | |
ChannelId | getId () const |
ProtocolVersion | getVersion () const |
RequestId | send (shared_ptr< AMQBody > body, Correlator::Action action=Correlator::Action()) |
Send a frame. | |
RequestId | send (AMQBody *body) |
void | handleMethod (shared_ptr< AMQMethodBody >) |
void | handleRequest (shared_ptr< AMQRequestBody >) |
void | handleResponse (shared_ptr< AMQResponseBody >) |
virtual bool | isOpen () const =0 |
Protected Member Functions | |
void | assertMethodOk (AMQMethodBody &method) const |
void | assertChannelOpen () const |
void | assertChannelNotOpen () const |
virtual void | handleMethodInContext (shared_ptr< AMQMethodBody > method, const MethodContext &context)=0 |
RequestId | getFirstAckRequest () |
RequestId | getLastAckRequest () |
RequestId | getNextSendRequestId () |
Thread safety: OBJECT UNSAFE. Instances must not be called concurrently. AMQP defines channels to be serialized.
qpid::framing::ChannelAdapter::ChannelAdapter | ( | ChannelId | id_ = 0 , |
|
OutputHandler * | out_ = 0 , |
|||
ProtocolVersion | ver = ProtocolVersion() | |||
) | [inline] |
output | Processed frames are forwarded to this handler. |
RequestId qpid::framing::ChannelAdapter::send | ( | AMQBody * | body | ) | [inline] |
RequestId qpid::framing::ChannelAdapter::send | ( | shared_ptr< AMQBody > | body, | |
Correlator::Action | action = Correlator::Action() | |||
) |
Send a frame.
body | Body of the frame. | |
action | optional action to execute when we receive a response to this frame. Ignored if body is not a Request. |