public SimpleConsumer getSimpleConsumer()

in rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java [82:95]

• 14 lines of code
• 4 McCabe index (conditional complexity)

    public SimpleConsumer getSimpleConsumer() {
        if (Objects.isNull(simpleConsumer)) {
            synchronized (RocketMQClientTemplate.class) {
                if (Objects.isNull(simpleConsumer)) {
                    try {
                        this.simpleConsumer = simpleConsumerBuilder.build();
                    } catch (ClientException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        }
        return simpleConsumer;
    }