qpid::broker::Channel Class Reference

Maintains state for an AMQP channel. More...

#include <BrokerChannel.h>

Inheritance diagram for qpid::broker::Channel:

Inheritance graph
[legend]
Collaboration diagram for qpid::broker::Channel:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 Channel (Connection &parent, framing::ChannelId id, uint32_t framesize, MessageStore *const _store=0, uint64_t stagingThreshold=0)
bool isOpen () const
BrokerAdaptergetAdatper ()
void open ()
void setDefaultQueue (Queue::shared_ptr queue)
Queue::shared_ptr getDefaultQueue () const
uint32_t setPrefetchSize (uint32_t size)
uint16_t setPrefetchCount (uint16_t n)
bool exists (const string &consumerTag)
void consume (string &tagInOut, Queue::shared_ptr queue, bool acks, bool exclusive, ConnectionToken *const connection=0, const framing::FieldTable *=0)
void cancel (const string &tag)
bool get (Queue::shared_ptr queue, const std::string &destination, bool ackExpected)
void begin ()
void close ()
void commit ()
void rollback ()
void ack ()
void ack (uint64_t deliveryTag, bool multiple)
void ack (uint64_t deliveryTag, uint64_t endTag)
void recover (bool requeue)
void deliver (Message::shared_ptr &msg, const string &consumerTag, uint64_t deliveryTag)
void handlePublish (Message *msg)
void handleHeader (boost::shared_ptr< framing::AMQHeaderBody >)
void handleContent (boost::shared_ptr< framing::AMQContentBody >)
void handleHeartbeat (boost::shared_ptr< framing::AMQHeartbeatBody >)
void handleInlineTransfer (Message::shared_ptr msg)
void handleMethodInContext (boost::shared_ptr< framing::AMQMethodBody > method, const framing::MethodContext &context)

Detailed Description

Maintains state for an AMQP channel.

Handles incoming and outgoing messages for that channel.


Member Function Documentation

void qpid::broker::Channel::consume ( string &  tagInOut,
Queue::shared_ptr  queue,
bool  acks,
bool  exclusive,
ConnectionToken *const   connection = 0,
const framing::FieldTable = 0 
)

Parameters:
tagInOut - if empty it is updated with the generated token.


The documentation for this class was generated from the following file:
Generated on Tue Apr 17 14:22:11 2007 for Qpid by  doxygen 1.4.7