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.
The consumer link is closed when the subscription is cancelled, unless the passed options request a
durable sub, in which case the link is only detached. A Dynamic address can be requested by setting
the dynamic option true.
@param connection
the connection to create the consumer with.
@param address
The source address to attach the consumer to, or null the 'dynamic' option is being used.
@param options
The options.
@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.
The consumer link is closed when the subscription is cancelled, unless the passed options request a durable sub, in which case the link is only detached. A Dynamic address can be requested by setting the dynamic option true.
@param connection the connection to create the consumer with. @param address The source address to attach the consumer to, or null the 'dynamic' option is being used. @param options The options. @return the consumers Publisher stream.