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

Packages that use MessageConsumer

Package	Description
io.vertx.mutiny.core.eventbus

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
MessageConsumer<T>	MessageConsumer.completionAndForget()	Unlike the bare Vert.x variant, this method ignores the Void result or any failure.
<T> MessageConsumer<T>	EventBus.consumer(io.vertx.core.eventbus.MessageConsumerOptions options)	Create a message consumer against the specified options address.
<T> MessageConsumer<T>	EventBus.consumer(io.vertx.core.eventbus.MessageConsumerOptions options, Consumer<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, Consumer<Message<T>> handler)	Create a consumer and register it against the specified address.
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)	Like EventBus.consumer(String) but the address won't be propagated across the cluster.
<T> MessageConsumer<T>	EventBus.localConsumer(String address, Consumer<Message<T>> handler)	Like #consumer(String, Handler) but the address won't be propagated across the cluster.
static <T> MessageConsumer<T>	MessageConsumer.newInstance(io.vertx.core.eventbus.MessageConsumer<T> delegate)	Creates a new instance of the MessageConsumer.
static <T> MessageConsumer<T>	MessageConsumer.newInstance(io.vertx.core.eventbus.MessageConsumer<T> delegate, TypeArg<T> typeArg_0)	Creates a new instance of the MessageConsumer.
MessageConsumer<T>	MessageConsumer.pause()
MessageConsumer<T>	MessageConsumer.pipeToAndForget(WriteStream<Message<T>> arg0)	Pipe this ReadStream to the WriteStream.
MessageConsumer<T>	MessageConsumer.resume()
MessageConsumer<T>	MessageConsumer.unregisterAndForget()	Unregisters the handler which created this registration