qpid::framing::ChannelAdapter Class Reference

Base class for client and broker channels. More...

#include <ChannelAdapter.h>

Inheritance diagram for qpid::framing::ChannelAdapter:

[legend]Collaboration diagram for qpid::framing::ChannelAdapter:

[legend]List of all members.

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 ()

---

Detailed Description

Base class for client and broker channels.

• receives frame bodies from the network.
• Updates request/response data.
• Dispatches requests with a MethodContext for responses.

send()

• Updates request/resposne ID data.
• Forwards frame to the peer.

Thread safety: OBJECT UNSAFE. Instances must not be called concurrently. AMQP defines channels to be serialized.

---

Constructor & Destructor Documentation

qpid::framing::ChannelAdapter::ChannelAdapter	(	ChannelId	id_ = 0,
		OutputHandler *	out_ = 0,
		ProtocolVersion	ver = ProtocolVersion()
	)			[inline]

Parameters:

output

Processed frames are forwarded to this handler.

---

Member Function Documentation

RequestId qpid::framing::ChannelAdapter::send

(

AMQBody *

body

)

[inline]

Deprecated:

Use make_shared_ptr with the other send() override

RequestId qpid::framing::ChannelAdapter::send	(	shared_ptr< AMQBody >	body,
		Correlator::Action	action = Correlator::Action()
	)

Send a frame.

Parameters:

	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.

Returns:

If body is a request, the ID assigned else 0.

---

The documentation for this class was generated from the following file:

• /home/aconway/svn/qpid/cpp/src/qpid/framing/ChannelAdapter.h

---