Package | Description |
---|---|
io.vertx.core.eventbus | |
io.vertx.reactivex.core.eventbus | |
io.vertx.rxjava.core.eventbus | |
io.vertx.rxjava3.core.eventbus |
Modifier and Type | Method and Description |
---|---|
MessageConsumerOptions |
MessageConsumerOptions.setAddress(String address)
Set the address the event-bus will register the consumer at.
|
MessageConsumerOptions |
MessageConsumerOptions.setLocalOnly(boolean localOnly)
Set whether the consumer is local only.
|
MessageConsumerOptions |
MessageConsumerOptions.setMaxBufferedMessages(int maxBufferedMessages)
Set the number of messages this registration will buffer when this stream is paused.
|
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options)
Create a message consumer against the specified options address.
|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options,
Handler<Message<T>> handler)
Create a consumer and register it against the specified options address.
|
Constructor and Description |
---|
MessageConsumerOptions(MessageConsumerOptions options) |
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options)
Create a message consumer against the specified options address.
|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options,
Handler<Message<T>> handler)
Create a consumer and register it against the specified options address.
|
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options)
Create a message consumer against the specified options address.
|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options,
Handler<Message<T>> handler)
Create a consumer and register it against the specified options address.
|
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options)
Create a message consumer against the specified options address.
|
<T> MessageConsumer<T> |
EventBus.consumer(MessageConsumerOptions options,
Handler<Message<T>> handler)
Create a consumer and register it against the specified options address.
|
Copyright © 2025 Eclipse. All rights reserved.