@Override
    public ConsumeStats examineConsumeStats(
        String consumerGroup) throws RemotingException, MQClientException, InterruptedException,
        MQBrokerException {
        return examineConsumeStats(consumerGroup, null);
    }
@Ignore
    @Test
    public void testExamineConsumeStats() throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
        ConsumeStats consumeStats = defaultMQAdminExt.examineConsumeStats("default-consumer-group", "unit-test");
        assertThat(consumeStats.getConsumeTps()).isGreaterThanOrEqualTo(1234);
        ConsumerConnection connection = new ConsumerConnection();
        connection.setMessageModel(MessageModel.BROADCASTING);
        HashSet<Connection> connections = new HashSet<>();
        connections.add(new Connection());
        connection.setConnectionSet(connections);
        when(mQClientAPIImpl.getConsumeStats(anyString(), anyString(), anyString(), anyLong()))
            .thenReturn(new ConsumeStats());
        when(mQClientAPIImpl.getConsumerConnectionList(anyString(), anyString(), anyLong()))
            .thenReturn(new ConsumerConnection()).thenReturn(connection);
        // CONSUMER_NOT_ONLINE
        try {
            defaultMQAdminExt.examineConsumeStats("default-consumer-group", "unit-test");
        } catch (Exception e) {
            assertThat(e instanceof MQClientException).isTrue();
            assertThat(((MQClientException) e).getResponseCode()).isEqualTo(ResponseCode.CONSUMER_NOT_ONLINE);
        }
        // BROADCAST_CONSUMPTION
        try {
            defaultMQAdminExt.examineConsumeStats("default-consumer-group", "unit-test");
        } catch (Exception e) {
            assertThat(e instanceof MQClientException).isTrue();
            assertThat(((MQClientException) e).getResponseCode()).isEqualTo(ResponseCode.BROADCAST_CONSUMPTION);
        }
    }