Creates an AMQP producer, presented as a reactive streams {@link org.reactivestreams.Subscriber Subscriber}.
The status of the message delivery, i.e whether the server peer accepts it etc, can be checked
using its containing tracker, which are created using {@link Tracker#create(Message, io.vertx.core.Handler)}
or {@link Tracker#create(Message)}.
The subscriber may only be subscribed once.
Must be called on the {@link io.vertx.core.Context} thread for the given connection.
If no address (i.e null) is specified then a producer will be established to the 'anonymous relay'
and each message sent must specify its individual destination address.
@param connection
the connection to create the consumer with.
@param address
The target address to attach the producer to (or null to send to the anonymous relay).
@return the producers Subscriber stream.
Creates an AMQP producer, presented as a reactive streams {@link org.reactivestreams.Subscriber Subscriber}.
The status of the message delivery, i.e whether the server peer accepts it etc, can be checked using its containing tracker, which are created using {@link Tracker#create(Message, io.vertx.core.Handler)} or {@link Tracker#create(Message)}.
The subscriber may only be subscribed once. Must be called on the {@link io.vertx.core.Context} thread for the given connection.
If no address (i.e null) is specified then a producer will be established to the 'anonymous relay' and each message sent must specify its individual destination address.
@param connection the connection to create the consumer with. @param address The target address to attach the producer to (or null to send to the anonymous relay). @return the producers Subscriber stream.