Package | Description |
---|---|
io.vertx.rxjava.core.eventbus |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Message> |
Message.__TYPE_ARG |
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) |
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> 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. |
Observable<Message<T>> |
MessageConsumer.toObservable() |
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)
Pipe this
ReadStream to the WriteStream . |
void |
MessageConsumer.pipeTo(WriteStream<Message<T>> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream . |
<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 . |
Copyright © 2021 Eclipse. All rights reserved.