@Test
public void testDecode2Message() throws Exception {

    byte[] inputByte = IPFIXUtilTestHelper.collectMessage("ONT1", "$6$SW2yXjnVMkUwIUeQ$c.JydO461NKo/VTgTYbvtEyVnKQhUr4NRFaFQD3YI5UfC28WTSewVAaR6UjloBFa.N4lVYrr1at25omRhbPOI.", "admin");
    byte[] inputByte2 = IPFIXUtilTestHelper.collectMessage("ONT1", "$6$SW2yXjnVMkUwIUeQ$c.JydO461NKo/VTgTYbvtEyVnKQhUr4NRFaFQD3YI5UfC28WTSewVAaR6UjloBFa.N4lVYrr1at25omRhbPOI.", "admin");
    byte[] testByte = ArrayUtils.addAll(inputByte, inputByte2);
    assertEquals(inputByte.length + inputByte2.length, testByte.length);
    IpfixMessageDecoder IpfixMessageDecoder = new IpfixMessageDecoder();
    ChannelHandlerContext ctx = mock(ChannelHandlerContext.class);
    List<Object> checkedList = new ArrayList<>();
    IpfixMessageDecoder.decode(ctx, Unpooled.wrappedBuffer(testByte), checkedList);
    assertEquals(2, checkedList.size());
    IpfixMessagesWrapper ipfixMessagesWrapper = (IpfixMessagesWrapper) checkedList.get(0);
    IpfixMessagesWrapper ipfixMessagesWrapper2 = (IpfixMessagesWrapper) checkedList.get(1);
    assertArrayEquals(inputByte, ipfixMessagesWrapper.getData());
    assertArrayEquals(inputByte2, ipfixMessagesWrapper2.getData());
}