Creates an AMQP consumer, presented as a reactive streams {@link org.reactivestreams.Publisher Publisher}.
Messages will be automatically accepted when the {@link org.reactivestreams.Subscriber#onNext(Object) Subscriber#onNext(Object)}
method returns. If you require more control over when the message is accepted, you should use
{@link #createDeliveryConsumer(ProtonConnection, String)} instead.
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 will be automatically accepted when the {@link org.reactivestreams.Subscriber#onNext(Object) Subscriber#onNext(Object)} method returns. If you require more control over when the message is accepted, you should use {@link #createDeliveryConsumer(ProtonConnection, String)} instead.
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.