    @Test
    public void filter() throws JoyQueueException {

        // Consumer consumer, List<ByteBuffer> byteBuffers, FilterCallback filterCallback
        List<ByteBuffer> byteBufferList = new LinkedList<>();
        for (int i = 0; i < 10; i++) {
            ByteBuffer allocate = ByteBuffer.allocate(100);
            allocate.position(59);
            allocate.putShort((short) i);
            allocate.flip();

            byteBufferList.add(allocate);
        }

        List<ByteBuffer> filter = filterMessageSupport.filter(consumer, byteBufferList, new FilterCallback() {
            @Override
            public void callback(List<ByteBuffer> list) throws JoyQueueException {
                // nothing to do;
                Assert.assertEquals(1, list.size());
            }
        });

        Assert.assertEquals(3, filter.size());
    }