public SchemaInfo updateSchema()

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

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

    public SchemaInfo updateSchema(SchemaInfo update) {
        byte[] schemaInfo = converter.toJsonAsBytes(update);

        try {
            synchronized (this) {
                Message msg = new Message(storageTopic, "", update.schemaFullName(), schemaInfo);
                SendResult result = sendOrderMessageToRocketmq(msg);
                if (result.getSendStatus() != SendStatus.SEND_OK) {
                    throw new SchemaException("Update " + update.getQualifiedName() + " failed: " + result.getSendStatus());
                }
                log.info("send message success, msgId = {}", result.getMsgId());
            }
            return update;
        } catch (SchemaException e) {
            throw e;
        } catch (Exception e) {
            throw new SchemaException("Update schema " + update.getQualifiedName() + " failed", e);
        }
    }