public interface Message<T>
Instances of this class are not thread-safe
Modifier and Type | Method and Description |
---|---|
java.lang.String |
address()
The address the message was sent to
|
T |
body()
The body of the message
|
void |
fail(int failureCode,
java.lang.String message)
Signal that processing of this message failed.
|
void |
reply()
Same as
reply(T message) but with an empty body |
void |
reply(java.lang.Boolean message)
Reply to this message.
|
<T> void |
reply(java.lang.Boolean message,
Handler<Message<T>> replyHandler)
The same as
reply(Boolean message) but you can specify handler for the reply - i.e. |
void |
reply(Buffer message)
Reply to this message.
|
<T> void |
reply(Buffer message,
Handler<Message<T>> replyHandler)
The same as
reply(Buffer message) but you can specify handler for the reply - i.e. |
void |
reply(byte[] message)
Reply to this message.
|
<T> void |
reply(byte[] message,
Handler<Message<T>> replyHandler)
The same as
reply(byte[] message) but you can specify handler for the reply - i.e. |
void |
reply(java.lang.Character message)
Reply to this message.
|
<T> void |
reply(java.lang.Character message,
Handler<Message<T>> replyHandler)
The same as
reply(Character message) but you can specify handler for the reply - i.e. |
void |
reply(java.lang.Double message)
Reply to this message.
|
<T> void |
reply(java.lang.Double message,
Handler<Message<T>> replyHandler)
The same as
reply(Double message) but you can specify handler for the reply - i.e. |
void |
reply(java.lang.Float message)
Reply to this message.
|
<T> void |
reply(java.lang.Float message,
Handler<Message<T>> replyHandler)
The same as
reply(Float message) but you can specify handler for the reply - i.e. |
<T> void |
reply(Handler<Message<T>> replyHandler)
The same as
reply() but you can specify handler for the reply - i.e. |
void |
reply(java.lang.Integer message)
Reply to this message.
|
<T> void |
reply(java.lang.Integer message,
Handler<Message<T>> replyHandler)
The same as
reply(Integer message) but you can specify handler for the reply - i.e. |
void |
reply(JsonArray message)
Reply to this message.
|
<T> void |
reply(JsonArray message,
Handler<Message<T>> replyHandler)
The same as
reply(JsonArray message) but you can specify handler for the reply - i.e. |
void |
reply(JsonObject message)
Reply to this message.
|
<T> void |
reply(JsonObject message,
Handler<Message<T>> replyHandler)
The same as
reply(JsonObject message) but you can specify handler for the reply - i.e. |
void |
reply(java.lang.Long message)
Reply to this message.
|
<T> void |
reply(java.lang.Long message,
Handler<Message<T>> replyHandler)
The same as
reply(Long message) but you can specify handler for the reply - i.e. |
void |
reply(java.lang.Object message)
Reply to this message.
|
<T> void |
reply(java.lang.Object message,
Handler<Message<T>> replyHandler)
The same as
reply(JsonObject message) but you can specify handler for the reply - i.e. |
void |
reply(java.lang.Short message)
Reply to this message.
|
<T> void |
reply(java.lang.Short message,
Handler<Message<T>> replyHandler)
The same as
reply(Short message) but you can specify handler for the reply - i.e. |
void |
reply(java.lang.String message)
Reply to this message.
|
<T> void |
reply(java.lang.String message,
Handler<Message<T>> replyHandler)
The same as
reply(String message) but you can specify handler for the reply - i.e. |
java.lang.String |
replyAddress()
The reply address (if any)
|
<T> void |
replyWithTimeout(java.lang.Boolean message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(Buffer message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(byte[] message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.Character message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.Double message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.Float message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.Integer message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(JsonArray message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(JsonObject message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.Long message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.Object message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.Short message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
<T> void |
replyWithTimeout(java.lang.String message,
long timeout,
Handler<AsyncResult<Message<T>>> replyHandler)
Reply to this message.
|
java.lang.String address()
T body()
java.lang.String replyAddress()
void reply()
reply(T message)
but with an empty bodyvoid reply(java.lang.Object message)
void reply(JsonObject message)
void reply(JsonArray message)
void reply(java.lang.String message)
void reply(Buffer message)
void reply(byte[] message)
void reply(java.lang.Integer message)
void reply(java.lang.Long message)
void reply(java.lang.Short message)
void reply(java.lang.Character message)
void reply(java.lang.Boolean message)
void reply(java.lang.Float message)
void reply(java.lang.Double message)
<T> void reply(Handler<Message<T>> replyHandler)
reply()
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Object message, Handler<Message<T>> replyHandler)
reply(JsonObject message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Object message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(JsonObject message, Handler<Message<T>> replyHandler)
reply(JsonObject message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(JsonObject message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(JsonArray message, Handler<Message<T>> replyHandler)
reply(JsonArray message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(JsonArray message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.String message, Handler<Message<T>> replyHandler)
reply(String message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.String message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(Buffer message, Handler<Message<T>> replyHandler)
reply(Buffer message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(Buffer message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(byte[] message, Handler<Message<T>> replyHandler)
reply(byte[] message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(byte[] message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Integer message, Handler<Message<T>> replyHandler)
reply(Integer message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Integer message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Long message, Handler<Message<T>> replyHandler)
reply(Long message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Long message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Short message, Handler<Message<T>> replyHandler)
reply(Short message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Short message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Character message, Handler<Message<T>> replyHandler)
reply(Character message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Character message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Boolean message, Handler<Message<T>> replyHandler)
reply(Boolean message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Boolean message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Float message, Handler<Message<T>> replyHandler)
reply(Float message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Float message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
<T> void reply(java.lang.Double message, Handler<Message<T>> replyHandler)
reply(Double message)
but you can specify handler for the reply - i.e.
to receive the reply to the reply.<T> void replyWithTimeout(java.lang.Double message, long timeout, Handler<AsyncResult<Message<T>>> replyHandler)
void fail(int failureCode, java.lang.String message)
failureCode
- A failure code to pass back to the sendermessage
- A message to pass back to the sender