Uses of Class
io.vertx.rxjava3.core.eventbus.Message
Packages that use Message
-
Uses of Message in io.vertx.rxjava3.core.eventbus
Classes in io.vertx.rxjava3.core.eventbus that implement interfaces with type arguments of type MessageModifier and TypeClassDescriptionclassAn event bus consumer object representing a stream of message to anEventBusaddress that can be read from.Fields in io.vertx.rxjava3.core.eventbus with type parameters of type MessageModifier and TypeFieldDescriptionstatic final io.vertx.lang.rx.TypeArg<Message> Message.__TYPE_ARGMethods in io.vertx.rxjava3.core.eventbus that return MessageModifier and TypeMethodDescriptionDeliveryContext.message()static <T> Message<T> Message.newInstance(Message arg) static <T> Message<T> Message.newInstance(Message arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T) Methods in io.vertx.rxjava3.core.eventbus that return types with arguments of type MessageModifier and TypeMethodDescriptionMessageConsumer.pipe()Pause this stream and return a to transfer the elements of this stream to a destination .Message.replyAndRequest(Object message) Reply to this message, specifying areplyHandlerfor the reply - i.e. to receive the reply to the reply.Message.replyAndRequest(Object message, DeliveryOptions options) LikeMessage.replyAndRequest(Object)but specifyingoptionsthat can be used to configure the delivery.Sends a message and specify areplyHandlerthat will be called if the recipient subsequently replies to the message.EventBus.request(String address, Object message, DeliveryOptions options) LikeEventBus.request(String, Object)but specifyingoptionsthat can be used to configure the delivery.Message.rxReplyAndRequest(Object message) Reply to this message, specifying areplyHandlerfor the reply - i.e. to receive the reply to the reply.Message.rxReplyAndRequest(Object message, DeliveryOptions options) LikeMessage.replyAndRequest(Object)but specifyingoptionsthat can be used to configure the delivery.Sends a message and specify areplyHandlerthat will be called if the recipient subsequently replies to the message.EventBus.rxRequest(String address, Object message, DeliveryOptions options) LikeEventBus.request(String, Object)but specifyingoptionsthat can be used to configure the delivery.MessageConsumer.toFlowable()MessageConsumer.toObservable()Method parameters in io.vertx.rxjava3.core.eventbus with type arguments of type MessageModifier and TypeMethodDescription<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 consumer and register it against the specified address.<T> MessageConsumer<T> EventBus.localConsumer(String address, Handler<Message<T>> handler) LikeEventBus.consumer(MessageConsumerOptions)but the address won't be propagated across the cluster.MessageConsumer.pipeTo(WriteStream<Message<T>> dst) Pipe thisReadStreamto theWriteStream.MessageConsumer.rxPipeTo(WriteStream<Message<T>> dst) Pipe thisReadStreamto theWriteStream.