Uses of Class
io.vertx.rxjava.core.eventbus.Message

Packages that use Message

Package	Description
io.vertx.rxjava.core.eventbus

Uses of Message in io.vertx.rxjava.core.eventbus

Fields in io.vertx.rxjava.core.eventbus with type parameters of type Message

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<Message>	Message.__TYPE_ARG

Methods in io.vertx.rxjava.core.eventbus that return Message

Modifier and Type	Method and Description
Message<T>	DeliveryContext.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.rxjava.core.eventbus that return types with arguments of type Message

Modifier and Type	Method and Description
Pipe<Message<T>>	MessageConsumer.pipe() Pause this stream and return a to transfer the elements of this stream to a destination .
<R> Observable<Message<R>>	Message.replyAndRequestObservable(Object message) Deprecated. use rxReplyAndRequest(java.lang.Object) instead
<R> Observable<Message<R>>	Message.replyAndRequestObservable(Object message, DeliveryOptions options) Deprecated. use rxReplyAndRequest(java.lang.Object) instead
<R> Observable<Message<R>>	Message.replyObservable(Object message) Deprecated. use rxReply(java.lang.Object) instead
<R> Observable<Message<R>>	Message.replyObservable(Object message, DeliveryOptions options) Deprecated. use rxReply(java.lang.Object) instead
<T> Observable<Message<T>>	EventBus.requestObservable(String address, Object message) Deprecated. use EventBus.rxRequest(java.lang.String, java.lang.Object) instead
<T> Observable<Message<T>>	EventBus.requestObservable(String address, Object message, DeliveryOptions options) Deprecated. use EventBus.rxRequest(java.lang.String, java.lang.Object) instead
<R> Single<Message<R>>	Message.rxReply(Object message) Deprecated.
<R> Single<Message<R>>	Message.rxReply(Object message, DeliveryOptions options) Deprecated.
<R> Single<Message<R>>	Message.rxReplyAndRequest(Object message) Reply to this message, specifying a replyHandler for the reply - i.e.
<R> Single<Message<R>>	Message.rxReplyAndRequest(Object message, DeliveryOptions options) Like but specifying options that can be used to configure the delivery.
<T> Single<Message<T>>	EventBus.rxRequest(String address, Object message) Sends a message and and specify a replyHandler that will be called if the recipient subsequently replies to the message.
<T> Single<Message<T>>	EventBus.rxRequest(String address, Object message, DeliveryOptions options) Like but specifying options that can be used to configure the delivery.
<T> Single<Message<T>>	EventBus.rxSend(String address, Object message) Deprecated.
<T> Single<Message<T>>	EventBus.rxSend(String address, Object message, DeliveryOptions options) Deprecated.
<T> Observable<Message<T>>	EventBus.sendObservable(String address, Object message) Deprecated. use EventBus.rxSend(java.lang.String, java.lang.Object) instead
<T> Observable<Message<T>>	EventBus.sendObservable(String address, Object message, DeliveryOptions options) Deprecated. use EventBus.rxSend(java.lang.String, java.lang.Object) instead
Observable<Message<T>>	MessageConsumer.toObservable()

Method parameters in io.vertx.rxjava.core.eventbus with type arguments of type Message

Modifier and Type	Method and Description
<T> MessageConsumer<T>	EventBus.consumer(String address, Handler<Message<T>> handler) Create a consumer and register it against the specified address.
MessageConsumer<T>	MessageConsumer.handler(Handler<Message<T>> handler)
<T> MessageConsumer<T>	EventBus.localConsumer(String address, Handler<Message<T>> handler) Like EventBus.consumer(java.lang.String) but the address won't be propagated across the cluster.
void	MessageConsumer.pipeTo(WriteStream<Message<T>> dst) Like ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler.
void	MessageConsumer.pipeTo(WriteStream<Message<T>> dst, Handler<AsyncResult<Void>> handler) Pipe this ReadStream to the WriteStream.
Observable<Void>	MessageConsumer.pipeToObservable(WriteStream<Message<T>> dst) Deprecated. use MessageConsumer.rxPipeTo(io.vertx.rxjava.core.streams.WriteStream<io.vertx.rxjava.core.eventbus.Message<T>>) instead
<R> void	Message.reply(Object message, DeliveryOptions options, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated.
<R> void	Message.reply(Object message, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated.
<R> void	Message.replyAndRequest(Object message, DeliveryOptions options, Handler<AsyncResult<Message<R>>> replyHandler) Like but specifying options that can be used to configure the delivery.
<R> void	Message.replyAndRequest(Object message, Handler<AsyncResult<Message<R>>> replyHandler) Reply to this message, specifying a replyHandler for the reply - i.e.
<T> EventBus	EventBus.request(String address, Object message, DeliveryOptions options, Handler<AsyncResult<Message<T>>> replyHandler) Like but specifying options that can be used to configure the delivery.
<T> EventBus	EventBus.request(String address, Object message, Handler<AsyncResult<Message<T>>> replyHandler) Sends a message and and specify a replyHandler that will be called if the recipient subsequently replies to the message.
Single<Void>	MessageConsumer.rxPipeTo(WriteStream<Message<T>> dst) Pipe this ReadStream to the WriteStream.
<T> EventBus	EventBus.send(String address, Object message, DeliveryOptions options, Handler<AsyncResult<Message<T>>> replyHandler) Deprecated.
<T> EventBus	EventBus.send(String address, Object message, Handler<AsyncResult<Message<T>>> replyHandler) Deprecated.
<R> MessageProducer<T>	MessageProducer.send(T message, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated.