io.vertx.core.eventbus.impl

Class MessageImpl<U,V>

java.lang.Object

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

All Implemented Interfaces:

Message<V>

Direct Known Subclasses:

ClusteredMessage

public class MessageImpl<U,V>
extends Object
implements Message<V>

Author:

Tim Fox

Field Summary

Fields

Modifier and Type	Field and Description
protected String	address
protected EventBusImpl	bus
protected MultiMap	headers
protected MessageCodec<U,V>	messageCodec
protected V	receivedBody
protected String	replyAddress
protected boolean	send
protected U	sentBody
protected Object	trace

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
String	address() The address the message was sent to
V	body() The body of the message.
MessageCodec<U,V>	codec()
MessageImpl<U,V>	copyBeforeReceive()
protected MessageImpl	createReply(Object message, DeliveryOptions options)
MultiMap	headers() Multi-map of message headers.
protected boolean	isLocal()
boolean	isSend() Signals if this message represents a send or publish event.
void	reply(Object message, DeliveryOptions options) Link Message.reply(Object) but allows you to specify delivery options for the reply.
String	replyAddress() The reply address.
<R> Future<Message<R>>	replyAndRequest(Object message, DeliveryOptions options) Like Message.replyAndRequest(Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result
void	setReplyAddress(String replyAddress)

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

Field Detail

messageCodec

protected MessageCodec<U,V> messageCodec

bus

protected final EventBusImpl bus

address

protected String address

replyAddress

protected String replyAddress

headers

protected MultiMap headers

sentBody

protected U sentBody

receivedBody

protected V receivedBody

send

protected boolean send

trace

protected Object trace

Constructor Detail

MessageImpl

public MessageImpl(EventBusImpl bus)

MessageImpl

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

MessageImpl

protected MessageImpl(MessageImpl<U,V> other)

Method Detail

copyBeforeReceive

public MessageImpl<U,V> copyBeforeReceive()

address

public String address()

Description copied from interface: Message

The address the message was sent to

Specified by:

address in interface Message<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>

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>

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>

Returns:

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

reply

public void reply(Object message,
                  DeliveryOptions options)

Description copied from interface: Message

Link Message.reply(Object) but allows you to specify delivery options for the reply.

Specified by:

reply in interface Message<V>

Parameters:

message - the reply message

options - the delivery options

replyAndRequest

public <R> Future<Message<R>> replyAndRequest(Object message,
                                              DeliveryOptions options)

Description copied from interface: Message

Like Message.replyAndRequest(Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result

Specified by:

replyAndRequest in interface Message<V>

createReply

protected MessageImpl createReply(Object message,
                                  DeliveryOptions options)

isSend

public boolean isSend()

Description copied from interface: Message

Signals if this message represents a send or publish event.

Specified by:

isSend in interface Message<V>

Returns:

true if this is a send.

setReplyAddress

public void setReplyAddress(String replyAddress)

codec

public MessageCodec<U,V> codec()

isLocal

protected boolean isLocal()