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

Packages that use MessageConsumer

Package	Description
io.vertx.mutiny.core.eventbus
io.vertx.mutiny.servicediscovery.types

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

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

Modifier and Type	Field	Description
static final TypeArg<MessageConsumer>	MessageConsumer.__TYPE_ARG

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

Modifier and Type	Method	Description
<T> MessageConsumer<T>	EventBus.consumer(String address)
<T> MessageConsumer<T>	EventBus.consumer(String address, Consumer<Message<T>> handler)
MessageConsumer<T>	MessageConsumer.endHandler(Runnable endHandler)
MessageConsumer<T>	MessageConsumer.exceptionHandler(Consumer<Throwable> handler)
MessageConsumer<T>	MessageConsumer.fetch(long amount)
MessageConsumer<T>	MessageConsumer.handler(Consumer<Message<T>> handler)
<T> MessageConsumer<T>	EventBus.localConsumer(String address)
<T> MessageConsumer<T>	EventBus.localConsumer(String address, Consumer<Message<T>> handler)
static <T> MessageConsumer<T>	MessageConsumer.newInstance(io.vertx.core.eventbus.MessageConsumer arg)
static <T> MessageConsumer<T>	MessageConsumer.newInstance(io.vertx.core.eventbus.MessageConsumer arg, TypeArg<T> __typeArg_T)
MessageConsumer<T>	MessageConsumer.pause()
MessageConsumer<T>	MessageConsumer.resume()
MessageConsumer<T>	MessageConsumer.setMaxBufferedMessages(int maxBufferedMessages)

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

Methods in io.vertx.mutiny.servicediscovery.types that return MessageConsumer

Modifier and Type	Method	Description
static <T> MessageConsumer<T>	MessageSource.getConsumerAndAwait(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter)	Blocking variant of MessageSource.getConsumer(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject).
static <T> MessageConsumer<T>	MessageSource.getConsumerAndAwait(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter)	Blocking variant of MessageSource.getConsumer(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function).

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

Modifier and Type	Method	Description
static <T> io.smallrye.mutiny.Uni<MessageConsumer<T>>	MessageSource.getConsumer(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter)	Convenient method that looks for a message source and provides the configured .
static <T> io.smallrye.mutiny.Uni<MessageConsumer<T>>	MessageSource.getConsumer(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter)	Convenient method that looks for a message source and provides the configured .