public T deserialize()

in client/src/main/java/org/apache/rocketmq/schema/registry/client/serde/json/JsonDeserializer.java [59:95]

• 30 lines of code
• 8 McCabe index (conditional complexity)

    public T deserialize(String subject, byte[] payload) {
        if (null == payload || payload.length == 0) {
            return null;
        }

        if (skipSchemaRegistry) {
            if (null == type) {
                throw new SerializationException("type cannot be null");
            }
            try {
                return objectMapper.readValue(payload, type);
            } catch (Exception e) {
                throw new SerializationException("JSON serialize failed", e);
            }
        }

        if (null == registryClient) {
            throw new SerializationException("please initialize the schema registry client first");
        }

        try {
            GetSchemaResponse response = registryClient.getSchemaBySubject(subject);
            ByteBuffer buffer = ByteBuffer.wrap(payload);

            long schemaRecordId = buffer.getLong();

            int length = buffer.limit() - SchemaConstants.SCHEMA_RECORD_ID_LENGTH;
            int start = buffer.position() + buffer.arrayOffset();

            JsonNode jsonNode = null;
            jsonNode = objectMapper.readValue(buffer.array(), start, length, JsonNode.class);

            return objectMapper.convertValue(jsonNode, type);
        } catch (RestClientException | IOException e) {
            throw new RuntimeException(e);
        }
    }