Uses of Class
io.vertx.reactivex.core.eventbus.MessageConsumer
-
Packages that use MessageConsumer Package Description io.vertx.reactivex.core.eventbus io.vertx.reactivex.ext.unit.collect io.vertx.reactivex.servicediscovery.types -
-
Uses of MessageConsumer in io.vertx.reactivex.core.eventbus
Fields in io.vertx.reactivex.core.eventbus with type parameters of type MessageConsumer Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<MessageConsumer>MessageConsumer. __TYPE_ARGMethods in io.vertx.reactivex.core.eventbus that return MessageConsumer Modifier and Type Method Description <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.<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)LikeEventBus.consumer(io.vertx.core.eventbus.MessageConsumerOptions)but the address won't be propagated across the cluster.<T> MessageConsumer<T>EventBus. localConsumer(String address, Handler<Message<T>> handler)LikeEventBus.consumer(io.vertx.core.eventbus.MessageConsumerOptions)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() -
Uses of MessageConsumer in io.vertx.reactivex.ext.unit.collect
Methods in io.vertx.reactivex.ext.unit.collect that return MessageConsumer Modifier and Type Method Description MessageConsumerEventBusCollector. register(String address)Register the collector as a consumer of the event bus with the specified address. -
Uses of MessageConsumer in io.vertx.reactivex.servicediscovery.types
Methods in io.vertx.reactivex.servicediscovery.types that return types with arguments of type MessageConsumer Modifier and Type Method Description static <T> Future<MessageConsumer<T>>MessageSource. getConsumer(ServiceDiscovery discovery, JsonObject filter)Convenient method that looks for a message source and provides the configured .static <T> Future<MessageConsumer<T>>MessageSource. getConsumer(ServiceDiscovery discovery, 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 .static <T> Single<MessageConsumer<T>>MessageSource. rxGetConsumer(ServiceDiscovery discovery, Function<Record,Boolean> filter)Convenient method that looks for a message source and provides the configured .
-