public GetSchemaResponse getTargetSchema()

in client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java [247:266]

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

    public GetSchemaResponse getTargetSchema(String subject, String schema)
        throws RestClientException, IOException {
        SubjectAndSchema subjectAndSchema = new SubjectAndSchema(DEFAULT_CLUSTER, DEFAULT_TENANT, subject, schema);
        GetSchemaResponse result = schemaCache.getIfPresent(subjectAndSchema);
        if (result != null) {
            return result;
        }
        result = restService.getTargetSchema(subject, schema);
        schemaCache.put(subjectAndSchema, result);

        String subjectFullName = String.format("%s/%s/%s", DEFAULT_CLUSTER, DEFAULT_TENANT, subject);
        Set<String> schemas = subjectToSchema.get(subjectFullName);
        if (schemas == null) {
            schemas = new HashSet<>();
        }
        schemas.add(schema);
        subjectToSchema.put(subjectFullName, schemas);

        return result;
    }