#include <BrokerChannel.h>
Inheritance diagram for qpid::broker::Channel:
Public Member Functions | |
Channel (Connection &parent, framing::ChannelId id, uint32_t framesize, MessageStore *const _store=0, uint64_t stagingThreshold=0) | |
bool | isOpen () const |
BrokerAdapter & | getAdatper () |
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) |
Handles incoming and outgoing messages for that channel.
void qpid::broker::Channel::consume | ( | string & | tagInOut, | |
Queue::shared_ptr | queue, | |||
bool | acks, | |||
bool | exclusive, | |||
ConnectionToken *const | connection = 0 , |
|||
const framing::FieldTable * | = 0 | |||
) |
tagInOut | - if empty it is updated with the generated token. |