public Message setEvent()

in src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQMessageWriter.java [82:86]

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

    public Message setEvent(final EventFormat format, final byte[] value) throws CloudEventRWException {
        message.putUserProperty(RocketMQHeaders.CONTENT_TYPE, format.serializedContentType());
        message.setBody(value);
        return message;
    }