public RegisterSchemaResponse registerSchema()

in core/src/main/java/org/apache/rocketmq/schema/registry/core/api/v1/SchemaController.java [143:165]

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

    public RegisterSchemaResponse registerSchema(
        @ApiParam(value = "The cluster of the subject", required = true)
        @PathVariable(value = "cluster-name") final String cluster,
        @ApiParam(value = "The tenant of the schema", required = true)
        @PathVariable(value = "tenant-name") final String tenant,
        @ApiParam(value = "The subject of the schema", required = true)
        @PathVariable(value = "subject-name") final String subject,
        @ApiParam(value = "The name of the schema", required = true)
        @PathVariable(value = "schema-name") final String schemaName,
        @ApiParam(value = "The schema detail", required = true)
        @RequestBody final RegisterSchemaRequest registerSchemaDto
    ) {
        // TODO: support register by sql
        final QualifiedName name = new QualifiedName(cluster, tenant, subject, schemaName);

        return this.requestProcessor.processRequest(
            name,
            "register",
            () -> {
                return this.schemaService.register(name, registerSchemaDto);
            }
        );
    }