private void init()

in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java [448:477]

• 24 lines of code
• 2 McCabe index (conditional complexity)

    private void init(Properties props) {
        this.useCompactTopic = Boolean.parseBoolean(props.getProperty(STORAGE_ROCKETMQ_USE_COMPACT_TOPIC,
            STORAGE_ROCKETMQ_USE_COMPACT_TOPIC_DEFAULT));
        String defaultTopic = useCompactTopic ? STORAGE_ROCKETMQ_COMPACT_TOPIC_DEFAULT : STORAGE_ROCKETMQ_TOPIC_DEFAULT;
        this.storageTopic = props.getProperty(STORAGE_ROCKETMQ_TOPIC, defaultTopic);
        this.cachePath = props.getProperty(STORAGE_LOCAL_CACHE_PATH, STORAGE_LOCAL_CACHE_PATH_DEFAULT);

        this.producer = new DefaultMQProducer(
            props.getProperty(STORAGE_ROCKETMQ_PRODUCER_GROUP, STORAGE_ROCKETMQ_PRODUCER_GROUP_DEFAULT)
        );

        this.producer.setNamesrvAddr(
            props.getProperty(STORAGE_ROCKETMQ_NAMESRV, STORAGE_ROCKETMQ_NAMESRV_DEFAULT)
        );

        this.consumer = new DefaultMQPushConsumer(
            props.getProperty(STORAGE_ROCKETMQ_CONSUMER_GROUP, STORAGE_ROCKETMQ_CONSUMER_GROUP_DEFAULT)
        );

        this.consumer.setNamesrvAddr(
            props.getProperty(STORAGE_ROCKETMQ_NAMESRV, STORAGE_ROCKETMQ_NAMESRV_DEFAULT)
        );

        this.mqAdminExt = new DefaultMQAdminExt();
        mqAdminExt.setNamesrvAddr(
            props.getProperty(STORAGE_ROCKETMQ_NAMESRV, STORAGE_ROCKETMQ_NAMESRV_DEFAULT)
        );

        this.converter = new JsonConverterImpl();
    }