vertx / io.vertx.reactivex.core.eventbus / EventBus / consumer

# consumer

`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.

### Parameters

`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.

### Parameters

`address` - the address that will register it at

`handler` - the handler that will process the received messages

Return
the event bus message consumer