public Object list()

in src/main/java/org/apache/rocketmq/dashboard/controller/TestController.java [52:100]
45 lines of code
4 McCabe index (conditional complexity)

    public Object list() throws MQClientException, RemotingException, InterruptedException {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(testTopic + "Group");
        consumer.setNamesrvAddr(rMQConfigure.getNamesrvAddr());
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
        consumer.subscribe(testTopic, "*");
        consumer.registerMessageListener(new MessageListenerConcurrently() {

            @Override
            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
                ConsumeConcurrentlyContext context) {
                logger.info("receiveMessage msgSize={}", msgs.size());
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        });
        consumer.start();
        final DefaultMQProducer producer = new DefaultMQProducer(testTopic + "Group");
        producer.setInstanceName(String.valueOf(System.currentTimeMillis()));
        producer.setNamesrvAddr(rMQConfigure.getNamesrvAddr());
        producer.start();

        new Thread(new Runnable() {

            @Override public void run() {

                int i = 0;
                while (true) {
                    try {
                        Message msg = new Message(testTopic,
                            "TagA" + i,
                            "KEYS" + i,
                            ("Hello RocketMQ " + i).getBytes()
                        );
                        Thread.sleep(1000L);
                        SendResult sendResult = producer.send(msg);
                        logger.info("sendMessage={}", JsonUtil.obj2String(sendResult));
                    }
                    catch (Exception e) {
                        e.printStackTrace();
                        try {
                            Thread.sleep(1000);
                        }
                        catch (Exception ignore) {
                        }
                    }
                }
            }
        }).start();
        return true;
    }