public class TestMessageSetSerDe {
@Test
public void test() {
TMessageSet messageSet = TestConnectionPool.createMessageSet(100);
MessageSetSerDe serde = new MessageSetSerDe();
byte[] payload = serde.serialize(messageSet);
TMessageSet d = serde.deserialize(payload);
assertTrue(Arrays.equals(d.getMessages(), messageSet.getMessages()));
List<Message> messageList = new LinkedList<Message>();