vertx / io.vertx.core.eventbus / EventBus / publisher

publisher

abstract fun <T : Any> publisher(address: String): MessageProducer<T>

Create a message publisher against the specified address.

The returned publisher will invoke the #publish(String, Object) method when the stream io.vertx.core.streams.WriteStream#write(Object) method is called with the publisher address and the provided data.

Parameters

address - The address to publish it to

Return
The publisher

abstract fun <T : Any> publisher(address: String, options: DeliveryOptions): MessageProducer<T>

Like #publisher(String) but specifying delivery options that will be used for configuring the delivery of the message.

Parameters

address - the address to publish it to

options - the delivery options

Return
The publisher