@Override
    public void submitPopConsumeRequest(final List<MessageExt> msgs,
                                     final PopProcessQueue processQueue,
                                     final MessageQueue messageQueue) {
        ConsumeRequest req = new ConsumeRequest(processQueue, messageQueue);
        submitConsumeRequest(req, false);
    }
@Test
    public void testSubmitPopConsumeRequest() throws IllegalAccessException {
        List<MessageExt> msgs = Collections.singletonList(createMessageExt());
        PopProcessQueue processQueue = mock(PopProcessQueue.class);
        MessageQueue messageQueue = mock(MessageQueue.class);
        ThreadPoolExecutor consumeExecutor = mock(ThreadPoolExecutor.class);
        FieldUtils.writeDeclaredField(popService, "consumeExecutor", consumeExecutor, true);
        popService.submitPopConsumeRequest(msgs, processQueue, messageQueue);
        verify(consumeExecutor, times(1)).submit(any(Runnable.class));
    }