Uses of Class
io.vertx.rxjava.core.eventbus.MessageConsumer

Packages that use MessageConsumer

Package	Description
io.vertx.rxjava.amqpbridge
io.vertx.rxjava.core.eventbus
io.vertx.rxjava.ext.unit.collect
io.vertx.rxjava.servicediscovery.types

Uses of MessageConsumer in io.vertx.rxjava.amqpbridge

Methods in io.vertx.rxjava.amqpbridge that return MessageConsumer

Modifier and Type	Method and Description
<T> MessageConsumer<T>	AmqpBridge.createConsumer(String amqpAddress) Creates a consumer on the given AMQP address.

Uses of MessageConsumer in io.vertx.rxjava.core.eventbus

Fields in io.vertx.rxjava.core.eventbus with type parameters of type MessageConsumer

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<MessageConsumer>	MessageConsumer.__TYPE_ARG

Methods in io.vertx.rxjava.core.eventbus that return MessageConsumer

Modifier and Type	Method and Description
<T> MessageConsumer<T>	EventBus.consumer(String address) Create a message consumer against the specified address.
<T> MessageConsumer<T>	EventBus.consumer(String address, Handler<Message<T>> handler) Create a consumer and register it against the specified address.
MessageConsumer<T>	MessageConsumer.endHandler(Handler<Void> endHandler)
MessageConsumer<T>	MessageConsumer.exceptionHandler(Handler<Throwable> handler)
MessageConsumer<T>	MessageConsumer.fetch(long amount)
MessageConsumer<T>	MessageConsumer.handler(Handler<Message<T>> handler)
<T> MessageConsumer<T>	EventBus.localConsumer(String address) Like EventBus.consumer(java.lang.String) but the address won't be propagated across the cluster.
<T> MessageConsumer<T>	EventBus.localConsumer(String address, Handler<Message<T>> handler) Like EventBus.consumer(java.lang.String) but the address won't be propagated across the cluster.
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg)
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)
MessageConsumer<T>	MessageConsumer.pause()
MessageConsumer<T>	MessageConsumer.resume()
MessageConsumer<T>	MessageConsumer.setMaxBufferedMessages(int maxBufferedMessages) Set the number of messages this registration will buffer when this stream is paused.

Uses of MessageConsumer in io.vertx.rxjava.ext.unit.collect

Methods in io.vertx.rxjava.ext.unit.collect that return MessageConsumer

Modifier and Type	Method and Description
MessageConsumer	EventBusCollector.register(String address) Register the collector as a consumer of the event bus with the specified address.

Uses of MessageConsumer in io.vertx.rxjava.servicediscovery.types

Methods in io.vertx.rxjava.servicediscovery.types that return types with arguments of type MessageConsumer

Modifier and Type	Method and Description
static <T> Single<MessageConsumer<T>>	MessageSource.rxGetConsumer(ServiceDiscovery discovery, java.util.function.Function<Record,Boolean> filter) Convenient method that looks for a message source and provides the configured .
static <T> Single<MessageConsumer<T>>	MessageSource.rxGetConsumer(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a message source and provides the configured .

Method parameters in io.vertx.rxjava.servicediscovery.types with type arguments of type MessageConsumer

Modifier and Type	Method and Description
static <T> void	MessageSource.getConsumer(ServiceDiscovery discovery, java.util.function.Function<Record,Boolean> filter, Handler<AsyncResult<MessageConsumer<T>>> resultHandler) Convenient method that looks for a message source and provides the configured .
static <T> void	MessageSource.getConsumer(ServiceDiscovery discovery, JsonObject filter, Handler<AsyncResult<MessageConsumer<T>>> resultHandler) Convenient method that looks for a message source and provides the configured .