Top Fields Constructors Methods
io.vertx.core.eventbus.impl

public Class MessageImpl<U, V>

extends Object
implements Message<V>
Class Inheritance
All Implemented Interfaces
io.vertx.core.eventbus.Message
Known Direct Subclasses
io.vertx.core.eventbus.impl.clustered.ClusteredMessage
Imports
io.vertx.core.Future, .MultiMap, io.vertx.core.eventbus.*, java.util.List, .Map

Author
Tim Fox

Field Summary

Modifier and TypeField and Description
protected String
protected final EventBusImpl
protected MultiMap
protected MessageCodec<U, V>
protected V
protected String
protected boolean
protected U
protected Object

Constructor Summary

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

protected
MessageImpl(MessageImpl<U, V> other)

Method Summary

Modifier and TypeMethod and Description
public String
address()

Implements io.vertx.core.eventbus.Message.address.

The address the message was sent to

public V
body()

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

The body of the message.

public MessageCodec<U, V>
public MessageImpl<U, V>
protected MessageImpl<U, V>
public MultiMap
headers()

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

Multi-map of message headers.

protected boolean
public boolean
isSend()

Implements io.vertx.core.eventbus.Message.isSend.

Signals if this message represents a send or publish event.

public void
reply(Object message, DeliveryOptions options)

public String
public <R> Future<Message<R>>
public void
setReplyAddress(String replyAddress)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

addressback to summary
protected String address
busback to summary
protected final EventBusImpl bus
headersback to summary
protected MultiMap headers
messageCodecback to summary
protected MessageCodec<U, V> messageCodec
receivedBodyback to summary
protected V receivedBody
replyAddressback to summary
protected String replyAddress
sendback to summary
protected boolean send
sentBodyback to summary
protected U sentBody
traceback to summary
protected Object trace

Constructor Detail

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

Method Detail

addressback to summary
public String address()

Implements io.vertx.core.eventbus.Message.address.

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

The address the message was sent to

Annotations
@Override
bodyback to summary
public V 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
codecback to summary
public MessageCodec<U, V> codec()
copyBeforeReceiveback to summary
public MessageImpl<U, V> copyBeforeReceive()
createReplyback to summary
protected MessageImpl<U, V> createReply(Object message, DeliveryOptions options)
headersback to summary
public MultiMap 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
isLocalback to summary
protected boolean isLocal()
isSendback to summary
public boolean isSend()

Implements io.vertx.core.eventbus.Message.isSend.

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

Signals if this message represents a send or publish event.

Returns:boolean

true if this is a send.

Annotations
@Override
replyback to summary
public void reply(Object message, DeliveryOptions options)
Annotations
@Override
replyAddressback to summary
public String 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
replyAndRequestback to summary
public <R> Future<Message<R>> replyAndRequest(Object message, DeliveryOptions options)
Annotations
@Override
setReplyAddressback to summary
public void setReplyAddress(String replyAddress)