public void deleteBySubject()

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

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

    public void deleteBySubject(QualifiedName name) {

        SchemaInfo schemaInfo = getSchemaInfoBySubject(name.subjectFullName());
        if (schemaInfo == null) {
            throw new SchemaNotFoundException(name);
        }

        try {
            synchronized (this) {
                schemaInfo.setLastModifiedTime(new Date());
                Message msg = new Message(storageTopic, "", schemaInfo.schemaFullName(), converter.toJsonAsBytes(schemaInfo));
                msg.putUserProperty(DELETE_KEYS, "true");
                SendResult result = sendOrderMessageToRocketmq(msg);
                if (!result.getSendStatus().equals(SendStatus.SEND_OK)) {
                    throw new SchemaException("Delete schema: " + name + " failed: " + result.getSendStatus());
                }
            }
        } catch (SchemaException e) {
            throw e;
        } catch (Exception e) {
            throw new SchemaException("Delete schema " + name + " failed", e);
        }
    }