#include <MessageMessageChannel.h>
Inheritance diagram for qpid::client::MessageMessageChannel:
Public Member Functions | |
MessageMessageChannel (Channel &parent) | |
void | consume (Queue &queue, std::string &tag, MessageListener *listener, AckMode ackMode=NO_ACK, bool noLocal=false, bool synch=true, const framing::FieldTable *fields=0) |
void | cancel (const std::string &tag, bool synch=true) |
bool | get (Message &msg, const Queue &queue, AckMode ackMode=NO_ACK) |
void | publish (const Message &msg, const Exchange &exchange, const std::string &routingKey, bool mandatory=false, bool immediate=false) |
void | setReturnedMessageHandler (ReturnedMessageHandler *handler) |
void | run () |
Derived classes override run(). | |
void | handle (boost::shared_ptr< framing::AMQMethodBody >) |
void | handle (shared_ptr< framing::AMQHeaderBody >) |
Handle an incoming header. | |
void | handle (shared_ptr< framing::AMQContentBody >) |
Handle an incoming content. | |
void | setQos () |
Send channel's QOS settings. | |
void | close () |
Channel is closing. |
void qpid::client::MessageMessageChannel::cancel | ( | const std::string & | tag, | |
bool | synch = true | |||
) | [virtual] |
void qpid::client::MessageMessageChannel::consume | ( | Queue & | queue, | |
std::string & | tag, | |||
MessageListener * | listener, | |||
AckMode | ackMode = NO_ACK , |
|||
bool | noLocal = false , |
|||
bool | synch = true , |
|||
const framing::FieldTable * | fields = 0 | |||
) | [virtual] |
void qpid::client::MessageMessageChannel::setReturnedMessageHandler | ( | ReturnedMessageHandler * | handler | ) | [virtual] |