public synchronized void unlockAllMessageQueues() {
        this.defaultMQPushConsumerImpl.getRebalanceImpl().unlockAll(false);
    }
@Test
    public void testUnlockAllMessageQueues() {
        popService.unlockAllMessageQueues();
        verify(rebalanceImpl, times(1)).unlockAll(eq(false));
    }