public static MessageReader createReader()

in src/main/java/org/apache/rocketmq/cloudevent/RocketMQMessageFactory.java [43:45]

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

    public static MessageReader createReader(final Message message) throws CloudEventRWException {
        return createReader(message.getProperties(), message.getBody());
    }