public RocketMQMessageWriter()

in src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQMessageWriter.java [49:61]

• 10 lines of code
• 5 McCabe index (conditional complexity)

    public RocketMQMessageWriter(String topic, String keys, String tags) {
        message = new Message();

        message.setTopic(topic);

        if (tags != null && tags.length() > 0) {
            message.setTags(tags);
        }

        if (keys != null && keys.length() > 0) {
            message.setKeys(keys);
        }
    }