public SchemaInfo getSchemaInfoBySubject()

in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java [407:415]

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

    public SchemaInfo getSchemaInfoBySubject(String subjectFullName) {
        byte[] lastRecordBytes = getBySubject(subjectFullName);
        if (lastRecordBytes == null) {
            return null;
        }
        SchemaRecordInfo lastRecord = converter.fromJson(lastRecordBytes, SchemaRecordInfo.class);
        byte[] result = getSchema(lastRecord.getSchema());
        return result == null ? null : converter.fromJson(result, SchemaInfo.class);
    }