Uses of Interface
io.vertx.core.eventbus.MessageConsumer

Packages that use MessageConsumer

Package	Description
io.vertx.core.eventbus
io.vertx.ext.unit.collect
io.vertx.reactivex.core.eventbus
io.vertx.rxjava.core.eventbus
io.vertx.rxjava3.core.eventbus
io.vertx.servicediscovery.types
io.vertx.serviceproxy

Uses of MessageConsumer in io.vertx.core.eventbus

Methods in io.vertx.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(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(String, Handler) but the address won't be propagated across the cluster.
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.ext.unit.collect

Methods in io.vertx.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.reactivex.core.eventbus

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

Modifier and Type	Method and Description
MessageConsumer	MessageConsumer.getDelegate()

Methods in io.vertx.reactivex.core.eventbus with parameters of type MessageConsumer

Modifier and Type	Method and Description
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg)
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Constructors in io.vertx.reactivex.core.eventbus with parameters of type MessageConsumer

Constructor and Description
MessageConsumer(MessageConsumer delegate)

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

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

Modifier and Type	Method and Description
MessageConsumer	MessageConsumer.getDelegate()

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

Modifier and Type	Method and Description
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg)
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

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

Constructor and Description
MessageConsumer(MessageConsumer delegate)

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

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

Modifier and Type	Method and Description
MessageConsumer	MessageConsumer.getDelegate()

Methods in io.vertx.rxjava3.core.eventbus with parameters of type MessageConsumer

Modifier and Type	Method and Description
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg)
static <T> MessageConsumer<T>	MessageConsumer.newInstance(MessageConsumer arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Constructors in io.vertx.rxjava3.core.eventbus with parameters of type MessageConsumer

Constructor and Description
MessageConsumer(MessageConsumer delegate)

Uses of MessageConsumer in io.vertx.servicediscovery.types

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

Modifier and Type	Method and Description
static <T> Future<MessageConsumer<T>>	MessageSource.getConsumer(ServiceDiscovery discovery, java.util.function.Function<Record,Boolean> filter) Like MessageSource.getConsumer(ServiceDiscovery, Function, Handler) but returns a future of the result
static <T> Future<MessageConsumer<T>>	MessageSource.getConsumer(ServiceDiscovery discovery, JsonObject filter) Like MessageSource.getConsumer(ServiceDiscovery, JsonObject, Handler) but returns a future of the result

Method parameters in io.vertx.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 MessageConsumer.
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 MessageConsumer.

Uses of MessageConsumer in io.vertx.serviceproxy

Fields in io.vertx.serviceproxy declared as MessageConsumer

Modifier and Type	Field and Description
protected MessageConsumer<JsonObject>	ProxyHandler.consumer

Methods in io.vertx.serviceproxy that return MessageConsumer

Modifier and Type	Method and Description
<T> MessageConsumer<JsonObject>	ServiceBinder.register(Class<T> clazz, T service) Registers a service on the event bus.
MessageConsumer<JsonObject>	ProxyHandler.register(EventBus eventBus, String address) Register the proxy handle on the event bus.
MessageConsumer<JsonObject>	ProxyHandler.register(Vertx vertx, String address, List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders) Register the proxy handle on the event bus.
<T> MessageConsumer<JsonObject>	ServiceBinder.registerLocal(Class<T> clazz, T service) Registers a local service on the event bus.
MessageConsumer<JsonObject>	ProxyHandler.registerLocal(EventBus eventBus, String address) Register the local proxy handle on the event bus.
MessageConsumer<JsonObject>	ProxyHandler.registerLocal(Vertx vertx, String address, List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders) Register the local proxy handle on the event bus.
static <T> MessageConsumer<JsonObject>	ProxyHelper.registerLocalService(Class<T> clazz, Vertx vertx, T service, String address) Deprecated. Registers a local service on the event bus.
static <T> MessageConsumer<JsonObject>	ProxyHelper.registerLocalService(Class<T> clazz, Vertx vertx, T service, String address, boolean topLevel, long timeoutSeconds) Deprecated.
static <T> MessageConsumer<JsonObject>	ProxyHelper.registerLocalService(Class<T> clazz, Vertx vertx, T service, String address, long timeoutSeconds) Deprecated.
static <T> MessageConsumer<JsonObject>	ProxyHelper.registerService(Class<T> clazz, Vertx vertx, T service, String address) Deprecated. Registers a service on the event bus.
static <T> MessageConsumer<JsonObject>	ProxyHelper.registerService(Class<T> clazz, Vertx vertx, T service, String address, boolean topLevel, long timeoutSeconds) Deprecated.
static <T> MessageConsumer<JsonObject>	ProxyHelper.registerService(Class<T> clazz, Vertx vertx, T service, String address, long timeoutSeconds) Deprecated.

Methods in io.vertx.serviceproxy with parameters of type MessageConsumer

Modifier and Type	Method and Description
void	ServiceBinder.unregister(MessageConsumer<JsonObject> consumer) Unregisters a published service.
static void	ProxyHelper.unregisterService(MessageConsumer<JsonObject> consumer) Deprecated. Unregisters a published service.