open fun <T : Any> consumer(address: String): MessageConsumer<T>
Create a message consumer against the specified address.
The returned consumer is not yet registered at the address, registration will be effective when io.vertx.reactivex.core.eventbus.MessageConsumer#handler is called.
address - the address that it will register it at
Return
the event bus message consumer
open fun <T : Any> consumer(address: String, handler: Handler<Message<T>>): MessageConsumer<T>
Create a consumer and register it against the specified address.
address - the address that will register it at
handler - the handler that will process the received messages
Return
the event bus message consumer