public ChannelFuture enqueue(Object message) {
        return enqueue(message, channel.newPromise());
    }
@Test
    public void testEnqueue() {
        Object message = new Object();
        ChannelFuture future = nettyBatchWriteQueue.enqueue(message);
        Assert.assertNotNull(future);

        Mockito.verify(mockEventLoop).execute(any(Runnable.class));
    }