Class MessageCodec

java.lang.Object

dev.moonbridge.messaging.protocol.MessageCodec

public final class MessageCodec
extends Object

Binary message frames shared by proxy-core and Java 8 backend clients.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	MessageCodec.IncomingMessage	Decoded inbound message with its hop-local acknowledgement operation and deadline.
static final class	MessageCodec.Response	Decoded response.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_FRAME_BYTES
static final int	MAX_NODE_BYTES
static final int	MAX_PUBLISH_RESULTS
static final long	MAX_TIMEOUT_MILLIS
static final int	MESSAGE
static final long	MIN_TIMEOUT_MILLIS
static final int	RESPONSE

Method Summary

Modifier and Type	Method	Description
static MessageCodec.IncomingMessage	decodeMessage(byte[] frame)
static MessageCodec.Response	decodeResponse(byte[] frame)
static byte[]	error(long operationId, MessagingException.Code code, String detail)
static byte[]	message(long operationId, long timeoutMillis, Message message)	Returns a message frame body (the transport adds the outer 4-byte length prefix).
static byte[]	published(long operationId, PublishResult result)
static byte[]	reply(long operationId, Message message)
static byte[]	sendResult(long operationId, SendResult result)

Methods inherited from class Object

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

Field Details

MESSAGE

public static final int MESSAGE

See Also:

• Constant Field Values

RESPONSE

public static final int RESPONSE

See Also:

• Constant Field Values

MAX_FRAME_BYTES

public static final int MAX_FRAME_BYTES

See Also:

• Constant Field Values

MAX_NODE_BYTES

public static final int MAX_NODE_BYTES

See Also:

• Constant Field Values

MAX_PUBLISH_RESULTS

public static final int MAX_PUBLISH_RESULTS

See Also:

• Constant Field Values

MIN_TIMEOUT_MILLIS

public static final long MIN_TIMEOUT_MILLIS

See Also:

• Constant Field Values

MAX_TIMEOUT_MILLIS

public static final long MAX_TIMEOUT_MILLIS

See Also:

• Constant Field Values

Method Details

message

public static byte[] message(long operationId,
 long timeoutMillis,
 Message message)
                      throws IOException

Returns a message frame body (the transport adds the outer 4-byte length prefix).

Throws:

IOException

decodeMessage

public static MessageCodec.IncomingMessage decodeMessage(byte[] frame)
                                                  throws IOException

Throws:

IOException

sendResult

public static byte[] sendResult(long operationId,
 SendResult result)
                         throws IOException

Throws:

IOException

reply

public static byte[] reply(long operationId,
 Message message)
                    throws IOException

Throws:

IOException

published

public static byte[] published(long operationId,
 PublishResult result)
                        throws IOException

Throws:

IOException

error

public static byte[] error(long operationId,
 MessagingException.Code code,
 String detail)
                    throws IOException

Throws:

IOException

decodeResponse

public static MessageCodec.Response decodeResponse(byte[] frame)
                                            throws IOException

Throws:

IOException