Package net.carcdr.yhocuspocus.redis

Class MessageCodec

java.lang.Object

net.carcdr.yhocuspocus.redis.MessageCodec

public final class MessageCodec
extends Object

Encodes and decodes Redis messages with instance ID prefix.

Message format:

 +----------------+------------------+--------------+
 | instanceIdLen  | instanceId       | payload      |
 | (4 bytes)      | (variable)       | (variable)   |
 +----------------+------------------+--------------+
 

The instance ID prefix allows receivers to filter out messages that originated from the same instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	MessageCodec.DecodedMessage	A decoded message containing instance ID and payload.

Method Summary

Modifier and Type	Method	Description
static MessageCodec.DecodedMessage	decode(byte[] message)	Decodes a message, extracting the instance ID.
static byte[]	encode(String instanceId, byte[] payload)	Encodes a message with instance ID prefix.

Methods inherited from class java.lang.Object

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

Method Details

encode

public static byte[] encode(String instanceId,
 byte[] payload)

Encodes a message with instance ID prefix.

Parameters:

instanceId - the originating instance ID

payload - the message payload

Returns:

the encoded message

decode

public static MessageCodec.DecodedMessage decode(byte[] message)

Decodes a message, extracting the instance ID.

Parameters:

message - the encoded message

Returns:

the decoded message, or null if message is invalid