open fun <T : Any> publisher(address: String): MessageProducer<T>
Create a message publisher against the specified address.
The returned publisher will invoke the io.vertx.rxjava.core.eventbus.EventBus#publish method when the stream io.vertx.rxjava.core.streams.WriteStream#write method is called with the publisher address and the provided data.
address - The address to publish it to
Return
The publisher
open fun <T : Any> publisher(address: String, options: DeliveryOptions): MessageProducer<T>
Like io.vertx.rxjava.core.eventbus.EventBus#publisher but specifying delivery options that will be used for configuring the delivery of the message.
address - the address to publish it to
options - the delivery options
Return
The publisher