public RocketMQMessageWriter()

in src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQMessageWriter.java [39:47]

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

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

        message.setTopic(topic);

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