Message-Queues beta 1.1
A Message-Queues based Cpp
 
载入中...
搜索中...
未找到
XuMQ::Channel 成员列表

成员的完整列表,这些成员属于 XuMQ::Channel,包括所有继承而来的类成员

_basic_respXuMQ::Channelprivate
_cidXuMQ::Channelprivate
_cmpXuMQ::Channelprivate
_codecXuMQ::Channelprivate
_connXuMQ::Channelprivate
_consumerXuMQ::Channelprivate
_cvXuMQ::Channelprivate
_hostXuMQ::Channelprivate
_mutexXuMQ::Channelprivate
_poolXuMQ::Channelprivate
basicAck(const std::string &msg_id)XuMQ::Channelinline
basicAck(const basicAckRequestPtr &req)XuMQ::Channelinline
basicCancel()XuMQ::Channelinline
basicCancel(const basicCancelRequestPtr &req)XuMQ::Channelinline
basicConsume(const std::string &tag, const std::string &qname, bool auto_ack, const ConsumerCallback &cb)XuMQ::Channelinline
basicConsume(const basicConsumeRequestPtr &req)XuMQ::Channelinline
basicPublish(const std::string &ename, const BasicProperties *bp, const std::string &body)XuMQ::Channelinline
basicPublish(const basicPublishRequestPtr &req)XuMQ::Channelinline
basicRespFunc(bool ok, const std::string &rid, const std::string &cid)XuMQ::Channelinlineprivate
callback(const std::string &tag, const BasicProperties *bp, const std::string &body)XuMQ::Channelinlineprivate
Channel(const muduo::net::TcpConnectionPtr &conn, const ProtobufCodecPtr &codec)XuMQ::Channelinline
Channel(const std::string &id, const VirtualHost::ptr &host, const ConsumerManager::ptr &cmp, const ProtobufCodecPtr &codec, const muduo::net::TcpConnectionPtr &conn, const threadpool::ptr &pool)XuMQ::Channelinline
cid()XuMQ::Channelinline
closeChannel()XuMQ::Channelinline
consume(const basicConsumeResponsePtr &resp)XuMQ::Channelinline
consume(const std::string &qname)XuMQ::Channelinlineprivate
declareExchange(const std::string &name, ExchangeType type, bool durable, bool auto_delete, google::protobuf::Map< std::string, std::string > &args)XuMQ::Channelinline
declareExchange(const declareExchangeRequestPtr &req)XuMQ::Channelinline
declareQueue(const std::string &qname, bool qdurable, bool qexclusive, bool qauto_delete, google::protobuf::Map< std::string, std::string > &qargs)XuMQ::Channelinline
declareQueue(const declareQueueRequestPtr &req)XuMQ::Channelinline
deleteExchange(const std::string &name)XuMQ::Channelinline
deleteExchange(const deleteExchangeRequestPtr &req)XuMQ::Channelinline
deleteQueue(const std::string &qname)XuMQ::Channelinline
deleteQueue(const deleteQueueRequestPtr &req)XuMQ::Channelinline
openChannel()XuMQ::Channelinline
ptr typedefXuMQ::Channel
ptr typedefXuMQ::Channel
putBasicResponse(const basicResponsePtr &resp)XuMQ::Channelinline
queueBind(const std::string &ename, const std::string &qname, const std::string &key)XuMQ::Channelinline
queueBind(const queueBindRequestPtr &req)XuMQ::Channelinline
queueUnBind(const std::string &ename, const std::string &qname)XuMQ::Channelinline
queueUnBind(const queueUnBindRequestPtr &req)XuMQ::Channelinline
waitResponse(const std::string &rid)XuMQ::Channelinlineprivate
~Channel()XuMQ::Channelinline
~Channel()XuMQ::Channelinline