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