public RocketMQMessageWriter create()

in src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQMessageWriter.java [76:79]

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

    public RocketMQMessageWriter<R> create(final SpecVersion version) {
        message.putUserProperty(RocketMQHeaders.SPEC_VERSION, version.toString());
        return this;
    }