public static RMQNormalProducer getRMQProducer()

in java/e2e-v4/src/main/java/org/apache/rocketmq/factory/ProducerFactory.java [38:53]

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

    public static RMQNormalProducer getRMQProducer(String ns, RPCHook rpcHook) {
        DefaultMQProducer producer;
        if (aclEnable) {
            producer = new DefaultMQProducer(RandomUtils.getStringByUUID(), rpcHook);
        } else {
            producer = new DefaultMQProducer(RandomUtils.getStringByUUID());
        }
        producer.setInstanceName(UUID.randomUUID().toString());
        producer.setNamesrvAddr(ns);
        try {
            producer.start();
        } catch (MQClientException e) {
            logger.info("Start DefaultMQProducer failed, {}", e.getMessage());
        }
        return new RMQNormalProducer(producer);
    }