public long maxOffset(MessageQueue mq) throws MQClientException {
        return this.mQClientFactory.getMQAdminImpl().maxOffset(mq);
    }
@Test
    public void testMaxOffset() throws MQClientException {
        assertEquals(0, defaultMQPushConsumerImpl.maxOffset(createMessageQueue()));
    }