Uses of Interface
io.vertx.core.eventbus.MessageConsumer
Packages that use MessageConsumer
-
Uses of MessageConsumer in io.vertx.core.eventbus
Methods in io.vertx.core.eventbus that return MessageConsumerModifier and TypeMethodDescription<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> Create a message consumer against the specified address.<T> MessageConsumer<T> Create a consumer and register it against the specified address.MessageConsumer.endHandler(Handler<Void> endHandler) MessageConsumer.exceptionHandler(Handler<Throwable> handler) MessageConsumer.fetch(long amount) <T> MessageConsumer<T> EventBus.localConsumer(String address) LikeEventBus.consumer(String)but the address won't be propagated across the cluster.<T> MessageConsumer<T> EventBus.localConsumer(String address, Handler<Message<T>> handler) LikeEventBus.consumer(String, Handler)but the address won't be propagated across the cluster.MessageConsumer.pause()MessageConsumer.resume()