public static MessageReader createReader()

in src/main/java/org/apache/rocketmq/cloudevent/RocketMQMessageFactory.java [48:56]

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

    public static MessageReader createReader(final Map<String, String> props, @Nullable final byte[] body) throws CloudEventRWException {

        return MessageUtils.parseStructuredOrBinaryMessage(
                () -> props.get(RocketMQHeaders.CONTENT_TYPE),
                format -> new GenericStructuredMessageReader(format, body),
                () -> props.get(RocketMQHeaders.SPEC_VERSION),
                sv -> new RocketMQBinaryMessageReader(sv, props, body)
        );
    }