cancel(const std::string &tag, bool synch=true)=0 | qpid::client::MessageChannel | [pure virtual] |
close()=0 | qpid::client::MessageChannel | [pure virtual] |
consume(Queue &queue, std::string &tag, MessageListener *listener, AckMode ackMode=NO_ACK, bool noLocal=false, bool synch=true, const framing::FieldTable *fields=0)=0 | qpid::client::MessageChannel | [pure virtual] |
Functor typedef | qpid::sys::Runnable | |
functor() | qpid::sys::Runnable | |
get(Message &msg, const Queue &queue, AckMode ackMode=NO_ACK)=0 | qpid::client::MessageChannel | [pure virtual] |
handle(shared_ptr< framing::AMQMethodBody >)=0 | qpid::client::MessageChannel | [pure virtual] |
handle(shared_ptr< framing::AMQHeaderBody >)=0 | qpid::client::MessageChannel | [pure virtual] |
handle(shared_ptr< framing::AMQContentBody >)=0 | qpid::client::MessageChannel | [pure virtual] |
publish(const Message &msg, const Exchange &exchange, const std::string &routingKey, bool mandatory=false, bool immediate=false)=0 | qpid::client::MessageChannel | [pure virtual] |
run()=0 | qpid::sys::Runnable | [pure virtual] |
setQos()=0 | qpid::client::MessageChannel | [pure virtual] |
setReturnedMessageHandler(ReturnedMessageHandler *handler)=0 | qpid::client::MessageChannel | [pure virtual] |
~Runnable() (defined in qpid::sys::Runnable) | qpid::sys::Runnable | [virtual] |