Interface used to consume AMQP message as a stream of message. Back pressure is implemented using AMQP credits.
See Source File