Uses of Class
io.vertx.core.eventbus.MessageConsumerOptions
Packages that use MessageConsumerOptions
Package
Description
-
Uses of MessageConsumerOptions in io.vertx.core.eventbus
Methods in io.vertx.core.eventbus that return MessageConsumerOptionsModifier and TypeMethodDescriptionMessageConsumerOptions.setAddress(String address) Set the address the event-bus will register the consumer at.MessageConsumerOptions.setLocalOnly(boolean localOnly) Set whether the consumer is local only.MessageConsumerOptions.setMaxBufferedMessages(int maxBufferedMessages) Set the number of messages this registration will buffer when this stream is paused.Methods in io.vertx.core.eventbus with parameters of type MessageConsumerOptionsModifier and TypeMethodDescription<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.Constructors in io.vertx.core.eventbus with parameters of type MessageConsumerOptionsModifierConstructorDescriptionCopy constructor -
Uses of MessageConsumerOptions in io.vertx.reactivex.core.eventbus
Methods in io.vertx.reactivex.core.eventbus with parameters of type MessageConsumerOptionsModifier and TypeMethodDescription<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. -
Uses of MessageConsumerOptions in io.vertx.rxjava3.core.eventbus
Methods in io.vertx.rxjava3.core.eventbus with parameters of type MessageConsumerOptionsModifier and TypeMethodDescription<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.