Vert.x 4.5.13 · io.vertx.core.eventbus.impl.clustered.ClusteredMessage

Field Summary

Modifier and Type	Field and Description
private int	bodyPos
private String	failure
private boolean	fromWire
private int	headersPos
private static final Logger	log
private String	repliedTo
private String	sender
private boolean	toWire
private static final byte	WIRE_PROTOCOL_VERSION
private Buffer	wireBuffer References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element.

Inherited from io.vertx.core.eventbus.impl.MessageImpl:: address bus headers messageCodec receivedBody replyAddress send sentBody trace

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
public V	body() Overrides io.vertx.core.eventbus.impl.MessageImpl.body. Implements io.vertx.core.eventbus.Message.body. The body of the message.
public ClusteredMessage<U, V>	copyBeforeReceive() Overrides io.vertx.core.eventbus.impl.MessageImpl.copyBeforeReceive.
protected MessageImpl<U, V>	createReply(Object message, DeliveryOptions options) Overrides io.vertx.core.eventbus.impl.MessageImpl.createReply.
private void	decodeBody()
private void	decodeHeaders()
private void	encodeHeaders(Buffer buffer) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element.
public Buffer	encodeToWire() References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element.
pack-priv String	getRepliedTo()
pack-priv String	getSender()
pack-priv boolean	hasFailure()
public MultiMap	headers() Overrides io.vertx.core.eventbus.impl.MessageImpl.headers. Implements io.vertx.core.eventbus.Message.headers. Multi-map of message headers.
pack-priv void	internalError()
public boolean	isFromWire()
protected boolean	isLocal() Overrides io.vertx.core.eventbus.impl.MessageImpl.isLocal.
public boolean	isToWire()
public void	readFromWire(Buffer buffer, CodecManager codecManager) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element.
public String	replyAddress() Overrides io.vertx.core.eventbus.impl.MessageImpl.replyAddress. Implements io.vertx.core.eventbus.Message.replyAddress. The reply address.
private void	setFailure(String s)
private void	writeBody(Buffer buff) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element.
private void	writeString(Buffer buff, String str) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element.

Inherited from io.vertx.core.eventbus.impl.MessageImpl:: address codec isSend reply replyAndRequest setReplyAddress

Field Detail

bodyPos	back to summary
private int bodyPos

failure	back to summary
private String failure

fromWire	back to summary
private boolean fromWire

headersPos	back to summary
private int headersPos

log	back to summary
private static final Logger log

repliedTo	back to summary
private String repliedTo

sender	back to summary
private String sender

toWire	back to summary
private boolean toWire

WIRE_PROTOCOL_VERSION	back to summary
private static final byte WIRE_PROTOCOL_VERSION

wireBuffer	back to summary
private Buffer wireBuffer References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

Constructor Detail

ClusteredMessage	back to summary
public ClusteredMessage(EventBusImpl bus)

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

ClusteredMessage	back to summary
protected ClusteredMessage(ClusteredMessage<U, V> other)

Method Detail

body	back to summary
public V body() Overrides io.vertx.core.eventbus.impl.MessageImpl.body. Implements io.vertx.core.eventbus.Message.body. Doc from io.vertx.core.eventbus.Message.body. The body of the message. Can be null. Returns:V the body, or null. Annotations @Override

body

back to summary

public V body()

Overrides io.vertx.core.eventbus.impl.MessageImpl.body.

Implements io.vertx.core.eventbus.Message.body.

Doc from io.vertx.core.eventbus.Message.body.

The body of the message. Can be null.

Returns:V

the body, or null.

Annotations

@Override

copyBeforeReceive	back to summary
public ClusteredMessage<U, V> copyBeforeReceive() Overrides io.vertx.core.eventbus.impl.MessageImpl.copyBeforeReceive.

createReply	back to summary
protected MessageImpl<U, V> createReply(Object message, DeliveryOptions options) Overrides io.vertx.core.eventbus.impl.MessageImpl.createReply. Annotations @Override

createReply

back to summary

protected MessageImpl<U, V> createReply(Object message, DeliveryOptions options)

Overrides io.vertx.core.eventbus.impl.MessageImpl.createReply.

Annotations

@Override

decodeBody	back to summary
private void decodeBody()

decodeHeaders	back to summary
private void decodeHeaders()

encodeHeaders	back to summary
private void encodeHeaders(Buffer buffer) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

encodeToWire	back to summary
public Buffer encodeToWire() References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

getRepliedTo	back to summary
pack-priv String getRepliedTo()

getSender	back to summary
pack-priv String getSender()

hasFailure	back to summary
pack-priv boolean hasFailure()

headers	back to summary
public MultiMap headers() Overrides io.vertx.core.eventbus.impl.MessageImpl.headers. Implements io.vertx.core.eventbus.Message.headers. Doc from io.vertx.core.eventbus.Message.headers. Multi-map of message headers. Can be empty Returns:MultiMap the headers Annotations @Override

headers

back to summary

public MultiMap headers()

Overrides io.vertx.core.eventbus.impl.MessageImpl.headers.

Implements io.vertx.core.eventbus.Message.headers.

Doc from io.vertx.core.eventbus.Message.headers.

Multi-map of message headers. Can be empty

Returns:MultiMap

the headers

Annotations

@Override

internalError	back to summary
pack-priv void internalError()

isFromWire	back to summary
public boolean isFromWire()

isLocal	back to summary
protected boolean isLocal() Overrides io.vertx.core.eventbus.impl.MessageImpl.isLocal.

isToWire	back to summary
public boolean isToWire()

readFromWire	back to summary
public void readFromWire(Buffer buffer, CodecManager codecManager) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

replyAddress	back to summary
public String replyAddress() Overrides io.vertx.core.eventbus.impl.MessageImpl.replyAddress. Implements io.vertx.core.eventbus.Message.replyAddress. Doc from io.vertx.core.eventbus.Message.replyAddress. The reply address. Can be null. Returns:String the reply address, or null, if message was sent without a reply handler. Annotations @Override

replyAddress

back to summary

public String replyAddress()

Overrides io.vertx.core.eventbus.impl.MessageImpl.replyAddress.

Implements io.vertx.core.eventbus.Message.replyAddress.

Doc from io.vertx.core.eventbus.Message.replyAddress.

The reply address. Can be null.

Returns:String

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

Annotations

@Override

setFailure	back to summary
private void setFailure(String s)

writeBody	back to summary
private void writeBody(Buffer buff) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

writeString	back to summary
private void writeString(Buffer buff, String str) References Deprecated `Buffer` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

public Class ClusteredMessage<U, V>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail