Creates an AMQP consumer, presented as a reactive streams {@link org.reactivestreams.Publisher Publisher}.
Messages are carried by {@link Delivery} elements of the stream, which are used by the consuming application
to explicitly acknowledge each message after processing it.
The publisher may only be subscribed to a single time.
Must be called on the {@link io.vertx.core.Context} thread for the given connection.
@param connection
the connection to create the consumer with.
@param address
The source address to attach the consumer to.
@return the consumers Publisher stream.
Creates an AMQP consumer, presented as a reactive streams {@link org.reactivestreams.Publisher Publisher}. Messages are carried by {@link Delivery} elements of the stream, which are used by the consuming application to explicitly acknowledge each message after processing it.
The publisher may only be subscribed to a single time. Must be called on the {@link io.vertx.core.Context} thread for the given connection.
@param connection the connection to create the consumer with. @param address The source address to attach the consumer to. @return the consumers Publisher stream.