public class Message<T> extends Object
 Messages have a body(), which can be null, and also headers(), which can be empty.
 
 If the message was sent specifying a reply handler, it can be replied to using reply(java.lang.Object).
 
 If you want to notify the sender that processing failed, then fail(int, java.lang.String) can be called.
 
original non RX-ified interface using Vert.x codegen.| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<Message> | 
__TYPE_ARG  | 
io.vertx.lang.rx.TypeArg<T> | 
__typeArg_0  | 
| Constructor and Description | 
|---|
Message(Message delegate)  | 
Message(Object delegate,
       io.vertx.lang.rx.TypeArg<T> typeArg_0)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
address()
The address the message was sent to 
 | 
T | 
body()
The body of the message. 
 | 
boolean | 
equals(Object o)  | 
void | 
fail(int failureCode,
    String message)
Signal to the sender that processing of this message failed. 
 | 
Message | 
getDelegate()  | 
int | 
hashCode()  | 
MultiMap | 
headers()
Multi-map of message headers. 
 | 
boolean | 
isSend()
Signals if this message represents a send or publish event. 
 | 
static <T> Message<T> | 
newInstance(Message arg)  | 
static <T> Message<T> | 
newInstance(Message arg,
           io.vertx.lang.rx.TypeArg<T> __typeArg_T)  | 
void | 
reply(Object message)
Reply to this message. 
 | 
void | 
reply(Object message,
     DeliveryOptions options)
Link  
reply(java.lang.Object) but allows you to specify delivery options for the reply. | 
<R> void | 
reply(Object message,
     DeliveryOptions options,
     Handler<AsyncResult<Message<R>>> replyHandler)
Deprecated.  
 | 
<R> void | 
reply(Object message,
     Handler<AsyncResult<Message<R>>> replyHandler)
Deprecated.  
 | 
String | 
replyAddress()
The reply address. 
 | 
<R> void | 
replyAndRequest(Object message,
               DeliveryOptions options,
               Handler<AsyncResult<Message<R>>> replyHandler)
Like  but specifying  
options that can be used
 to configure the delivery. | 
<R> void | 
replyAndRequest(Object message,
               Handler<AsyncResult<Message<R>>> replyHandler)
Reply to this message, specifying a  
replyHandler for the reply - i.e. | 
<R> Single<Message<R>> | 
rxReply(Object message)
Deprecated.  
 | 
<R> Single<Message<R>> | 
rxReply(Object message,
       DeliveryOptions options)
Deprecated.  
 | 
<R> Single<Message<R>> | 
rxReplyAndRequest(Object message)
Reply to this message, specifying a  
replyHandler for the reply - i.e. | 
<R> Single<Message<R>> | 
rxReplyAndRequest(Object message,
                 DeliveryOptions options)
Like  but specifying  
options that can be used
 to configure the delivery. | 
String | 
toString()  | 
public static final io.vertx.lang.rx.TypeArg<Message> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<T> __typeArg_0
public Message(Message delegate)
public Message getDelegate()
public String address()
public MultiMap headers()
public T body()
public String replyAddress()
public boolean isSend()
public void reply(Object 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.
message - the message to reply with.@Deprecated public <R> void reply(Object message, Handler<AsyncResult<Message<R>>> replyHandler)
reply(R message) but you can specify handler for the reply - i.e.
 to receive the reply to the reply.message - the message to reply with.replyHandler - the reply handler for the reply.@Deprecated public <R> Single<Message<R>> rxReply(Object message)
reply(R message) but you can specify handler for the reply - i.e.
 to receive the reply to the reply.message - the message to reply with.public void reply(Object message, DeliveryOptions options)
reply(java.lang.Object) but allows you to specify delivery options for the reply.message - the reply messageoptions - the delivery options@Deprecated public <R> void reply(Object message, DeliveryOptions options, Handler<AsyncResult<Message<R>>> replyHandler)
reply(R message, DeliveryOptions) but you can specify handler for the reply - i.e.
 to receive the reply to the reply.message - the reply messageoptions - the delivery optionsreplyHandler - the reply handler for the reply.@Deprecated public <R> Single<Message<R>> rxReply(Object message, DeliveryOptions options)
reply(R message, DeliveryOptions) but you can specify handler for the reply - i.e.
 to receive the reply to the reply.message - the reply messageoptions - the delivery optionspublic <R> void replyAndRequest(Object message, Handler<AsyncResult<Message<R>>> replyHandler)
replyHandler for the reply - i.e.
 to receive the reply to the reply.
 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.
message - the message to reply with.replyHandler - the reply handler for the reply.public <R> Single<Message<R>> rxReplyAndRequest(Object message)
replyHandler for the reply - i.e.
 to receive the reply to the reply.
 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.
message - the message to reply with.public <R> void replyAndRequest(Object message, DeliveryOptions options, Handler<AsyncResult<Message<R>>> replyHandler)
options that can be used
 to configure the delivery.message - the message body, may be nulloptions - delivery optionsreplyHandler - reply handler will be called when any reply from the recipient is receivedpublic <R> Single<Message<R>> rxReplyAndRequest(Object message, DeliveryOptions options)
options that can be used
 to configure the delivery.message - the message body, may be nulloptions - delivery optionspublic void fail(int failureCode,
                 String message)
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.
failureCode - A failure code to pass back to the sendermessage - A message to pass back to the senderCopyright © 2020 Eclipse. All rights reserved.