Uses of Interface
io.vertx.core.eventbus.MessageConsumer
Packages that use MessageConsumer
Package
Description
-
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() -
Uses of MessageConsumer in io.vertx.ext.unit.collect
Methods in io.vertx.ext.unit.collect that return MessageConsumerModifier and TypeMethodDescriptionRegister 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 MessageConsumerMethods in io.vertx.reactivex.core.eventbus with parameters of type MessageConsumerModifier and TypeMethodDescriptionstatic <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 -
Uses of MessageConsumer in io.vertx.rxjava3.core.eventbus
Methods in io.vertx.rxjava3.core.eventbus that return MessageConsumerMethods in io.vertx.rxjava3.core.eventbus with parameters of type MessageConsumerModifier and TypeMethodDescriptionstatic <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 -
Uses of MessageConsumer in io.vertx.servicediscovery.types
Methods in io.vertx.servicediscovery.types that return types with arguments of type MessageConsumerModifier and TypeMethodDescriptionstatic <T> Future<MessageConsumer<T>> MessageSource.getConsumer(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a message source and provides the configuredMessageConsumer.static <T> Future<MessageConsumer<T>> MessageSource.getConsumer(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a message source and provides the configuredMessageConsumer. -
Uses of MessageConsumer in io.vertx.serviceproxy
Fields in io.vertx.serviceproxy declared as MessageConsumerMethods in io.vertx.serviceproxy that return MessageConsumerModifier and TypeMethodDescriptionRegister the proxy handle on the event bus.ProxyHandler.register(Vertx vertx, String address, List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders) Register the proxy handle on the event bus.Registers a service on the event bus.ProxyHandler.registerLocal(EventBus eventBus, String address) Register the local proxy handle on the event bus.ProxyHandler.registerLocal(Vertx vertx, String address, List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders) Register the local proxy handle on the event bus.ServiceBinder.registerLocal(Class<T> clazz, T service) Registers a local service on the event bus.Methods in io.vertx.serviceproxy with parameters of type MessageConsumerModifier and TypeMethodDescriptionvoidServiceBinder.unregister(MessageConsumer<JsonObject> consumer) Unregisters a published service.