implement (non)blocking consumer support
Sharded AMQP class