Creates an AMQP producer, presented as a reactive streams {@link org.reactivestreams.Subscriber Subscriber}.
The status of the message delivery can not be tracked after send, if you need that ability use
{@link ProtonStreams#createTrackerProducer(ProtonConnection, String, ProtonSubscriberOptions)}.
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).
@param options
The options.
@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 can not be tracked after send, if you need that ability use {@link ProtonStreams#createTrackerProducer(ProtonConnection, String, ProtonSubscriberOptions)}.
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). @param options The options. @return the producers Subscriber stream.