public RocketMQBinaryMessageReader()

in src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java [32:37]

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

    public RocketMQBinaryMessageReader(SpecVersion version, Map<String, String> headers, byte[] payload) {
        super(version, payload != null && payload.length > 0 ? BytesCloudEventData.wrap(payload) : null);

        Objects.requireNonNull(headers);
        this.headers = headers;
    }