private DefaultMQPullConsumer buildPullConsumer()

in src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminInstance.java [86:102]

• 17 lines of code
• 3 McCabe index (conditional complexity)

    private DefaultMQPullConsumer buildPullConsumer() throws Exception {
        String namesrvAddress = configure.getNamesrvAddr();
        if (StringUtils.isBlank(namesrvAddress)) {
            log.error("init default pull consumer error, namesrv is null");
            throw new Exception("init default pull consumer error, namesrv is null", null);
        }
        DefaultMQPullConsumer pullConsumer = new DefaultMQPullConsumer(TOOLS_CONSUMER_GROUP, this.aclHook);
        pullConsumer.setInstanceName("consumer-" + System.currentTimeMillis());
        pullConsumer.setNamesrvAddr(namesrvAddress);
        try {
            pullConsumer.start();
            pullConsumer.getDefaultMQPullConsumerImpl().getPullAPIWrapper().setConnectBrokerByUser(true);
        } catch (MQClientException ex) {
            log.error(String.format("init default pull consumer error, namesrv=%s", System.getProperty(MixAll.NAMESRV_ADDR_PROPERTY)), ex);
        }
        return pullConsumer;
    }