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 TypeArg<MessageConsumer>MessageConsumer. __TYPE_ARGMethods 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. registrationAndAwait()Blocking variant ofregistration().MessageConsumer<T>MessageConsumer. resume()MessageConsumer<T>MessageConsumer. setMaxBufferedMessages(int maxBufferedMessages)Methods in io.vertx.mutiny.core.eventbus that return types with arguments of type MessageConsumer Modifier and Type Method Description io.smallrye.mutiny.Uni<MessageConsumer<T>>MessageConsumer. registration()Unlike the bare Vert.x variant, this method returns aUni. -
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)static <T> MessageConsumer<T>MessageSource. getConsumerAndAwait(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter)Blocking variant ofio.vertx.mutiny.servicediscovery.types.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 .
-