AMQP_08 enum value (defined in qpid::client::Channel) | qpid::client::Channel | |
AMQP_09 enum value (defined in qpid::client::Channel) | qpid::client::Channel | |
assertChannelNotOpen() const (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [protected] |
assertChannelOpen() const (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [protected] |
assertMethodOk(AMQMethodBody &method) const (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [protected] |
bind(const Exchange &exchange, const Queue &queue, const std::string &key, const framing::FieldTable &args, bool synch=true) | qpid::client::Channel | |
cancel(const std::string &tag, bool synch=true) | qpid::client::Channel | |
Channel(bool transactional=false, u_int16_t prefetch=500, InteropMode=AMQP_08) | qpid::client::Channel | |
ChannelAdapter(ChannelId id_=0, OutputHandler *out_=0, ProtocolVersion ver=ProtocolVersion()) | qpid::framing::ChannelAdapter | [inline] |
close(framing::ReplyCode=200, const std::string &="OK", framing::ClassId=0, framing::MethodId=0) | qpid::client::Channel | |
commit() | qpid::client::Channel | |
consume(Queue &queue, std::string &tag, MessageListener *listener, AckMode ackMode=NO_ACK, bool noLocal=false, bool synch=true, const framing::FieldTable *fields=0) | qpid::client::Channel | |
declareExchange(Exchange &exchange, bool synch=true) | qpid::client::Channel | |
declareQueue(Queue &queue, bool synch=true) | qpid::client::Channel | |
deleteExchange(Exchange &exchange, bool synch=true) | qpid::client::Channel | |
deleteQueue(Queue &queue, bool ifunused=false, bool ifempty=false, bool synch=true) | qpid::client::Channel | |
get(Message &msg, const Queue &queue, AckMode ackMode=NO_ACK) | qpid::client::Channel | |
getConnection() | qpid::client::Channel | [inline] |
getFirstAckRequest() (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [inline, protected] |
getId() const (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [inline] |
getLastAckRequest() (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [inline, protected] |
getNextSendRequestId() (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [inline, protected] |
getPrefetch() (defined in qpid::client::Channel) | qpid::client::Channel | [inline] |
getVersion() const | qpid::client::Channel | [inline] |
handleBody(boost::shared_ptr< AMQBody > body) (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [virtual] |
handleContent(boost::shared_ptr< AMQContentBody >)=0 (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [protected, pure virtual] |
handleHeader(boost::shared_ptr< AMQHeaderBody >)=0 (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [protected, pure virtual] |
handleHeartbeat(boost::shared_ptr< AMQHeartbeatBody >)=0 (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [protected, pure virtual] |
handleMethod(shared_ptr< AMQMethodBody >) (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | |
handleMethod(boost::shared_ptr< AMQMethodBody >)=0 (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [protected, pure virtual] |
handleMethodInContext(shared_ptr< AMQMethodBody > method, const MethodContext &context)=0 (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | [protected, pure virtual] |
handleRequest(shared_ptr< AMQRequestBody >) (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | |
handleRequest(boost::shared_ptr< AMQRequestBody >)=0 (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [protected, pure virtual] |
handleResponse(shared_ptr< AMQResponseBody >) (defined in qpid::framing::ChannelAdapter) | qpid::framing::ChannelAdapter | |
handleResponse(boost::shared_ptr< AMQResponseBody >)=0 (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [protected, pure virtual] |
init(ChannelId, OutputHandler &, ProtocolVersion) | qpid::framing::ChannelAdapter | |
InteropMode enum name (defined in qpid::client::Channel) | qpid::client::Channel | |
isOpen() const | qpid::client::Channel | [virtual] |
isTransactional() | qpid::client::Channel | [inline] |
publish(const Message &msg, const Exchange &exchange, const std::string &routingKey, bool mandatory=false, bool immediate=false) | qpid::client::Channel | |
rollback() | qpid::client::Channel | |
run() | qpid::client::Channel | |
send(shared_ptr< AMQBody > body, Correlator::Action action=Correlator::Action()) | qpid::framing::ChannelAdapter | |
send(AMQBody *body) | qpid::framing::ChannelAdapter | [inline] |
setPrefetch(uint16_t prefetch) | qpid::client::Channel | |
setReturnedMessageHandler(ReturnedMessageHandler *handler) | qpid::client::Channel | |
start() | qpid::client::Channel | |
~BodyHandler() (defined in qpid::framing::BodyHandler) | qpid::framing::BodyHandler | [virtual] |
~Channel() (defined in qpid::client::Channel) | qpid::client::Channel | |