@@ -0,0 +1,969 @@
+package io.atomix.cluster.messaging.impl;%0A%0Aimport io.atomix.cluster.NodeId;%0Aimport org.junit.Assert;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0Apublic class ClusterMessageTest %7B%0A%0A    private ClusterMessage clusterMessage;%0A%0A    @Before%0A    public void setUp() throws Exception %7B%0A        clusterMessage = new ClusterMessage(NodeId.from(%22node1%22), %22subject%22, new byte%5B%5D%7B1, 3, 3, 7%7D);%0A    %7D%0A%0A    @Test%0A    public void testMessageFromBytes() throws Exception %7B%0A        ClusterMessage message = ClusterMessage.fromBytes(clusterMessage.getBytes());%0A        Assert.assertArrayEquals(clusterMessage.payload(), message.payload());%0A        Assert.assertEquals(clusterMessage.subject(), message.subject());%0A        Assert.assertEquals(clusterMessage.sender(), message.sender());%0A    %7D%0A%0A    @Test%0A    public void testPayloadFromBytes() throws Exception %7B%0A        Assert.assertArrayEquals(clusterMessage.payload(), ClusterMessage.getPayload(clusterMessage.getBytes()));%0A    %7D%0A%7D%0A

Add unit test.