public MessageExt viewMessage(String topic, String msgId)
        throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
        return this.mQClientFactory.getMQAdminImpl().viewMessage(topic, msgId);
    }
@Test
    public void testViewMessage() throws InterruptedException, MQClientException, MQBrokerException, RemotingException {
        assertNull(defaultMQPushConsumerImpl.viewMessage(defaultTopic, createMessageExt().getMsgId()));
    }