public CloudEventContextWriter withContextAttribute()

in src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQMessageWriter.java [65:73]

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

    public CloudEventContextWriter withContextAttribute(String name, String value) throws CloudEventRWException {

        String propName = RocketMQHeaders.ATTRIBUTES_TO_HEADERS.get(name);
        if (propName == null) {
            propName = RocketMQHeaders.CE_PREFIX + name;
        }
        message.putUserProperty(propName, value);
        return this;
    }