Member BloombergLP::rmqa::VHost::createConsumer (const rmqp::Topology &topology, rmqt::QueueHandle queue, const rmqp::Consumer::ConsumerFunc &onMessage, const bsl::string &consumerTag, uint16_t prefetchCount=rmqt::ConsumerConfig::s_defaultPrefetchCount)
Member BloombergLP::rmqa::VHost::generateConsumerTag (): use rmqt::ConsumerConfig::generateConsumerTag()
Member BloombergLP::rmqp::Consumer::cancelAndDrain (const bsls::TimeInterval &timeout)=0