#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. |
1.4.7