io.vertx.core.eventbus.impl.clustered

Class ClusteredMessage<U,V>

java.lang.Object

io.vertx.core.eventbus.impl.MessageImpl<U,V>

io.vertx.core.eventbus.impl.clustered.ClusteredMessage<U,V>

All Implemented Interfaces:

Message<V>

public class ClusteredMessage<U,V>
extends MessageImpl<U,V>

Author:

Tim Fox

Field Summary

Fields inherited from class io.vertx.core.eventbus.impl.MessageImpl

address, bus, headers, messageCodec, receivedBody, replyAddress, send, sentBody, trace

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClusteredMessage(ClusteredMessage<U,V> other)
	ClusteredMessage(EventBusImpl bus)
	ClusteredMessage(String sender, String address, MultiMap headers, U sentBody, MessageCodec<U,V> messageCodec, boolean send, EventBusImpl bus)

Method Summary

Modifier and Type	Method and Description
V	body() The body of the message.
ClusteredMessage<U,V>	copyBeforeReceive()
protected MessageImpl	createReply(Object message, DeliveryOptions options)
Buffer	encodeToWire()
MultiMap	headers() Multi-map of message headers.
boolean	isFromWire()
protected boolean	isLocal()
boolean	isToWire()
void	readFromWire(Buffer buffer, CodecManager codecManager)
String	replyAddress() The reply address.

Methods inherited from class io.vertx.core.eventbus.impl.MessageImpl

address, codec, isSend, reply, replyAndRequest, setReplyAddress

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.vertx.core.eventbus.Message

fail, reply, replyAndRequest, replyAndRequest, replyAndRequest

Constructor Detail

ClusteredMessage

public ClusteredMessage(EventBusImpl bus)

ClusteredMessage

public ClusteredMessage(String sender,
                        String address,
                        MultiMap headers,
                        U sentBody,
                        MessageCodec<U,V> messageCodec,
                        boolean send,
                        EventBusImpl bus)

ClusteredMessage

protected ClusteredMessage(ClusteredMessage<U,V> other)

Method Detail

createReply

protected MessageImpl createReply(Object message,
                                  DeliveryOptions options)

Overrides:

createReply in class MessageImpl<U,V>

copyBeforeReceive

public ClusteredMessage<U,V> copyBeforeReceive()

Overrides:

copyBeforeReceive in class MessageImpl<U,V>

headers

public MultiMap headers()

Description copied from interface: Message

Multi-map of message headers. Can be empty

Specified by:

headers in interface Message<V>

Overrides:

headers in class MessageImpl<U,V>

Returns:

the headers

body

public V body()

Description copied from interface: Message

The body of the message. Can be null.

Specified by:

body in interface Message<V>

Overrides:

body in class MessageImpl<U,V>

Returns:

the body, or null.

replyAddress

public String replyAddress()

Description copied from interface: Message

The reply address. Can be null.

Specified by:

replyAddress in interface Message<V>

Overrides:

replyAddress in class MessageImpl<U,V>

Returns:

the reply address, or null, if message was sent without a reply handler.

encodeToWire

public Buffer encodeToWire()

readFromWire

public void readFromWire(Buffer buffer,
                         CodecManager codecManager)

isFromWire

public boolean isFromWire()

isToWire

public boolean isToWire()

isLocal

protected boolean isLocal()

Overrides:

isLocal in class MessageImpl<U,V>