Class JsonSchemaDeserializer<T>

Namespace

Solace.SchemaRegistry.Serdes.JsonSchema

Assembly

Solace.SchemaRegistry.Serdes.JsonSchema.dll

A deserializer for JSON Schema-formatted data that converts byte arrays into objects of type T. This class extends AbstractDeserializer<Schema, T> and implements the deserialization logic specific to JSON schemas. Returns a specific target object of type T or a JSON object when the target deserialized type cannot be determined.

public class JsonSchemaDeserializer<T> : AbstractDeserializer<JsonSchemaModel, T>, IAsyncDeserializer<T>, IDisposable

Type Parameters

T

The type of object this deserializer produces.

Inheritance

object

AbstractDeserializer<JsonSchemaModel, T>

JsonSchemaDeserializer<T>

Implements

IAsyncDeserializer<T>

IDisposable

Inherited Members

AbstractDeserializer<JsonSchemaModel, T>.SchemaResolver

AbstractDeserializer<JsonSchemaModel, T>.Configure(IDictionary<string, object>)

AbstractDeserializer<JsonSchemaModel, T>.SetSchemaParser(ISchemaParser<JsonSchemaModel>)

AbstractDeserializer<JsonSchemaModel, T>.DeserializePayload(ISchemaLookupResult<JsonSchemaModel>, ReadOnlyMemory<byte>, IMetadata, CancellationToken)

AbstractDeserializer<JsonSchemaModel, T>.Dispose(bool)

AbstractDeserializer<JsonSchemaModel, T>.Dispose()

AbstractDeserializer<JsonSchemaModel, T>.DeserializeAsync(string, ReadOnlyMemory<byte>, IDictionary<string, object>, CancellationToken)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

JsonSchemaDeserializer<T> requires schema resolution through headers for proper operation. Schema ID must be available during deserialization to resolve the payload schema.

Note: This deserializer establishes connections that may prevent application exit. Always call Dispose() when finished to properly clean up resources.

Methods

Configure(IDictionary<string, object>)

Configures this deserializer with the specified properties.

public override void Configure(IDictionary<string, object> properties)

Parameters

properties IDictionary<string, object>

A dictionary containing configuration properties for the deserializer

DeserializePayload(ISchemaLookupResult<JsonSchemaModel>, ReadOnlyMemory<byte>, IMetadata, CancellationToken)

Deserializes the payload data using the resolved JSON schema.

protected override ValueTask<T> DeserializePayload(ISchemaLookupResult<JsonSchemaModel> schemaLookup, ReadOnlyMemory<byte> payload, IMetadata metadata, CancellationToken token)

Parameters

schemaLookup ISchemaLookupResult<JsonSchemaModel>

The resolved schema lookup result containing the JSON schema

payload ReadOnlyMemory<byte>

The byte array payload to deserialize

metadata IMetadata

Metadata containing the destination name and headers for the deserialization context

token CancellationToken

Cancellation token for the operation

Returns

ValueTask<T>

The deserialized object of type T

Exceptions

JsonSchemaValidationException

Thrown when JSON schema validation fails

SerializationException

Thrown when deserialization fails

OperationCanceledException

Thrown when the operation is canceled via the cancellation token