Class Message

java.lang.Object

dev.moonbridge.messaging.Message

public final class Message
extends Object

Immutable message envelope shared by the proxy and Java 8 backend clients. The UUID identifies a message for tracing and request/reply correlation; it does not imply durable delivery, deduplication, or exactly-once processing. Sending APIs assign the source from the authenticated host identity.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_CHANNEL_BYTES
static final int	MAX_PAYLOAD_BYTES

Constructor Summary

Constructors

Constructor	Description
Message(UUID id, MessageKind kind, String channel, Endpoint source, Endpoint target, UUID replyTo, byte[] payload)	Creates a decoded message.

Method Summary

Modifier and Type	Method	Description
String	channel()
static Message	event(String channel, Endpoint source, Endpoint target, byte[] payload)
UUID	id()
MessageKind	kind()
byte[]	payload()	Returns a defensive copy of the payload.
static Message	reply(Message request, Endpoint source, byte[] payload)
UUID	replyTo()
static Message	request(String channel, Endpoint source, Endpoint target, byte[] payload)
Endpoint	source()
Endpoint	target()
static String	validateChannel(String channel)

Methods inherited from class Object

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

Field Details

MAX_PAYLOAD_BYTES

public static final int MAX_PAYLOAD_BYTES

See Also:

• Constant Field Values

MAX_CHANNEL_BYTES

public static final int MAX_CHANNEL_BYTES

See Also:

• Constant Field Values

Constructor Details

Message

public Message(UUID id,
 MessageKind kind,
 String channel,
 Endpoint source,
 Endpoint target,
 UUID replyTo,
 byte[] payload)

Creates a decoded message. Sending APIs replace the source with their authenticated host identity.

Method Details

event

public static Message event(String channel,
 Endpoint source,
 Endpoint target,
 byte[] payload)

request

public static Message request(String channel,
 Endpoint source,
 Endpoint target,
 byte[] payload)

reply

public static Message reply(Message request,
 Endpoint source,
 byte[] payload)

id

public UUID id()

kind

public MessageKind kind()

channel

public String channel()

source

public Endpoint source()

target

public Endpoint target()

replyTo

public UUID replyTo()

payload

public byte[] payload()

Returns a defensive copy of the payload.

validateChannel

public static String validateChannel(String channel)