Namespace Silverback.Messaging.Serialization

Classes

AvroMessageDeserializer<TMessage>

Connects to the specified schema registry and deserializes the messages from Apache Avro format.

AvroMessageSerializer<TMessage>

Connects to the specified schema registry and serializes the messages in Apache Avro format.

DeserializerConsumerBehavior

Deserializes the messages being consumed using the configured IMessageSerializer.

JsonMessageDeserializer<TMessage>

Deserializes the JSON messages into an instance of TMessage.

JsonMessageSerializer

Serializes the messages as JSON.

JsonSchemaRegistryMessageDeserializer<TMessage>

Connects to the specified schema registry and deserializes the JSON messages into an instance of TMessage.

JsonSchemaRegistryMessageSerializer<TMessage>

Connects to the specified schema registry and serializes the messages as JSON.

MessageEncodingExtensions

Adds a method to convert a MessageEncoding enum value to an Encoding instance.

MessageSerializerException

The exception that is thrown by the IMessageSerializer implementations when the message cannot be serialized or deserialized. This exception is thrown only when a Silverback specific error occurs, other exceptions related to reflection or the underlying serializer are not wrapped.

NewtonsoftJsonMessageDeserializer<TMessage>

Deserializes the JSON messages into an instance of TMessage.

NewtonsoftJsonMessageSerializer

Serializes the messages as JSON.

ProtobufMessageDeserializer<TMessage>

Connects to the specified schema registry and deserializes the messages from Protobuf format.

ProtobufMessageSerializer<TMessage>

Connects to the specified schema registry and serializes the messages in Protobuf format.

RawMessageDeserializer<T>

Wraps the received message into a RawMessage.

RawMessageSerializer

This serializer just passed the RawMessage raw content to the producer.

SchemaRegistryMessageDeserializer<TMessage>

Connects to the specified schema registry and deserializes the messages.

SchemaRegistryMessageSerializer<TMessage>

Connects to the specified schema registry and deserializes the messages.

SerializerProducerBehavior

Serializes the message being produced using the configured IMessageSerializer.

StringMessageDeserializer<T>

Decodes the received string and wraps it into a StringMessage.

StringMessageSerializer

Serializes a simple string.

Structs

DeserializedMessage

The result of DeserializeAsync(Stream?, MessageHeaderCollection, ConsumerEndpoint).

Interfaces

IConfluentSchemaRegistryClientFactory

The factory used to create Confluent.SchemaRegistry.ISchemaRegistryClient instances.

IMessageDeserializer

Deserializes the messages consumed from broker.

IMessageSerializer

Serializes the messages produced to the broker.

Enums

JsonMessageDeserializerTypeHeaderBehavior

Specifies how the IMessageDeserializer has to deserialize according to the message type header.

MessageEncoding

Specifies the message encoding.