public class ClusteredMessage<U,V> extends MessageImpl<U,V>
address, bus, headers, messageCodec, receivedBody, replyAddress, send, sentBody, writeHandler| Modifier | Constructor and Description |
|---|---|
|
ClusteredMessage() |
protected |
ClusteredMessage(ClusteredMessage<U,V> other) |
|
ClusteredMessage(ServerID sender,
String address,
String replyAddress,
MultiMap headers,
U sentBody,
MessageCodec<U,V> messageCodec,
boolean send,
EventBusImpl bus,
Handler<AsyncResult<Void>> writeHandler) |
| Modifier and Type | Method and Description |
|---|---|
V |
body()
The body of the message.
|
ClusteredMessage<U,V> |
copyBeforeReceive() |
Buffer |
encodeToWire() |
MultiMap |
headers()
Multi-map of message headers.
|
boolean |
isFromWire() |
protected boolean |
isLocal() |
void |
readFromWire(Buffer buffer,
CodecManager codecManager) |
String |
replyAddress()
The reply address.
|
address, codec, fail, isSend, reply, reply, reply, reply, sendReply, setBus, setReplyAddress, writeHandlerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitreplyAndRequest, replyAndRequestpublic ClusteredMessage()
public ClusteredMessage(ServerID sender, String address, String replyAddress, MultiMap headers, U sentBody, MessageCodec<U,V> messageCodec, boolean send, EventBusImpl bus, Handler<AsyncResult<Void>> writeHandler)
protected ClusteredMessage(ClusteredMessage<U,V> other)
public ClusteredMessage<U,V> copyBeforeReceive()
copyBeforeReceive in class MessageImpl<U,V>public MultiMap headers()
Messagepublic V body()
Messagepublic String replyAddress()
MessagereplyAddress in interface Message<V>replyAddress in class MessageImpl<U,V>public Buffer encodeToWire()
public void readFromWire(Buffer buffer, CodecManager codecManager)
public boolean isFromWire()
protected boolean isLocal()
isLocal in class MessageImpl<U,V>Copyright © 2020. All rights reserved.