open class Message<T : Any>
Represents a message that is received from the event bus in a handler.
Messages have a io.vertx.reactivex.core.eventbus.Message#body, which can be null, and also io.vertx.reactivex.core.eventbus.Message#headers, which can be empty.
If the message was sent specifying a reply handler it will also have a io.vertx.reactivex.core.eventbus.Message#replyAddress. In that case the message can be replied to using that reply address, or, more simply by just using io.vertx.reactivex.core.eventbus.Message#reply.
If you want to notify the sender that processing failed, then io.vertx.reactivex.core.eventbus.Message#fail can be called.
Message(delegate: Message<Any>)Message(delegate: Message<Any>, typeArg_0: TypeArg<T>) |
static val __TYPE_ARG: TypeArg<Message<Any>> |
|
val __typeArg_0: TypeArg<T> |
open fun address(): String
The address the message was sent to |
|
open fun body(): T
The body of the message. Can be null. |
|
open fun equals(other: Any?): Boolean |
|
open fun fail(failureCode: Int, message: String): Unit
Signal to the sender that processing of this message failed. If the message was sent specifying a result handler the handler will be called with a failure corresponding to the failure code and message specified here. |
|
open fun getDelegate(): Message<Any> |
|
open fun hashCode(): Int |
|
open fun headers(): MultiMap
Multi-map of message headers. Can be empty |
|
open fun isSend(): Boolean
Signals if this message represents a send or publish event. |
|
open static fun <T : Any> newInstance(arg: Message<Any>): Message<T>open static fun <T : Any> newInstance(arg: Message<Any>, __typeArg_T: TypeArg<T>): Message<T> |
|
open fun reply(message: Any): Unit
Reply to this message. If the message was sent specifying a reply handler, that handler will be called when it has received a reply. If the message wasn't sent specifying a receipt handler this method does nothing. open fun <R : Any> reply(message: Any, replyHandler: Handler<AsyncResult<Message<R>>>): Unit
The same as open fun reply(message: Any, options: DeliveryOptions): Unit
Link open fun <R : Any> reply(message: Any, options: DeliveryOptions, replyHandler: Handler<AsyncResult<Message<R>>>): Unit
The same as |
|
open fun replyAddress(): String
The reply address. Can be null. |
|
open fun <R : Any> rxReply(message: Any): Single<Message<R>>
The same as open fun <R : Any> rxReply(message: Any, options: DeliveryOptions): Single<Message<R>>
The same as |
|
open fun toString(): String |