public synchronized void lockMQPeriodically() {
        if (!this.stopped) {
            this.defaultMQPushConsumerImpl.getRebalanceImpl().lockAll();
        }
    }
@Test
    public void testLockMQPeriodically() {
        popService.lockMQPeriodically();
        verify(defaultMQPushConsumerImpl, times(1)).getRebalanceImpl();
        verify(rebalanceImpl, times(1)).lockAll();
    }