Namespace Silverback.Messaging.Configuration

Classes

AvroMessageDeserializerBuilder

Builds the AvroMessageDeserializer<TMessage>.

AvroMessageSerializerBuilder

Builds the AvroMessageSerializer<TMessage>.

BinaryMessageDeserializerBuilder

Builds the BinaryMessageDeserializer<TModel>.

BinaryMessageSerializerBuilder

Builds the BinaryMessageSerializer.

BrokerClientConnectionOptions

The options specifying if and when the broker clients have to be automatically connected.

BrokerClientsConfigurationBuilder

Configures the producers and consumers.

BrokerClientsInitializer

Initializes the broker clients, producers and consumers.

BrokerConfigurationException

The exception that is thrown when the broker client configuration is not valid.

BrokerOptionsBuilder

Exposes the methods to configure the connection with the message broker(s) and add the necessary services to the IServiceCollection.

BrokerOptionsBuilderAddConfluentSchemaRegistryExtensions

Adds the AddConfluentSchemaRegistry(BrokerOptionsBuilder) method to the BrokerOptionsBuilder.

BrokerOptionsBuilderAddKafkaExtensions

Adds the AddKafka method to the BrokerOptionsBuilder.

BrokerOptionsBuilderAddMqttExtensions

Adds the AddMqtt method to the BrokerOptionsBuilder.

BrokerOptionsBuilderEntityFrameworkExtensions

Adds the Silverback.Storage.EntityFramework specific methods to the BrokerOptionsBuilder.

BrokerOptionsBuilderKafkaTestingExtensions

Adds the AddMockedKafka method to the BrokerOptionsBuilder.

BrokerOptionsBuilderMemoryExtensions

Adds the Silverback.Storage.Memory specific methods to the BrokerOptionsBuilder.

BrokerOptionsBuilderMqttTestingExtensions

Adds the AddMockedMqtt method to the BrokerOptionsBuilder.

BrokerOptionsBuilderPostgreSqlExtensions

Adds the Silverback.Storage.PostgreSql specific methods to the BrokerOptionsBuilder.

BrokerOptionsBuilderSqliteExtensions

Adds the Silverback.Storage.Sqlite specific methods to the BrokerOptionsBuilder.

BusOptions

Stores the message bus configuration (subscribers, etc.).

ConsumerConfigurationBuilderNewtonsoftExtensions

Adds the DeserializeJsonUsingNewtonsoft method to the ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>.

ConsumerEndpointConfiguration

The consumer configuration.

ConsumerEndpointConfigurationBuilderSchemaRegistryExtensions

Adds the DeserializeAvro<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<AvroMessageDeserializerBuilder>?), DeserializeJsonUsingSchemaRegistry<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<JsonSchemaRegistryMessageDeserializerBuilder>?) and DeserializeProtobuf<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<ProtobufMessageDeserializerBuilder>?) methods to the ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>.

ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

Builds the ConsumerEndpointConfiguration.

EndpointConfiguration

The base class for ProducerEndpointConfiguration and ConsumerEndpointConfiguration.

EndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

Builds the EndpointConfiguration.

EndpointsConfigurationBuilderAddKafkaClientsExtensions

Adds the AddKafkaEndpoints method to the BrokerClientsConfigurationBuilder.

EndpointsConfigurationBuilderAddMqttEndpointsExtensions

Adds the AddMqttEndpoints method to the BrokerClientsConfigurationBuilder.

EntityFrameworkKafkaOffsetStoreSettingsBuilder

Builds the EntityFrameworkKafkaOffsetStoreSettings.

EntityFrameworkOutboxSettingsBuilder

Builds the EntityFrameworkOutboxSettings.

ErrorPolicyBaseBuilder<TBuilder>

Builds an ErrorPolicyBase.

InMemoryKafkaOffsetStoreSettingsBuilder

Builds the InMemoryKafkaOffsetStoreSettings.

InMemoryOutboxSettingsBuilder

Builds the InMemoryOutboxSettings.

JsonMessageDeserializerBuilder

Builds the JsonMessageDeserializer<TMessage>.

JsonMessageSerializerBuilder

Builds the JsonMessageSerializer.

JsonSchemaRegistryMessageDeserializerBuilder

Builds the JsonSchemaRegistryMessageDeserializer<TMessage>.

JsonSchemaRegistryMessageSerializerBuilder

Builds the JsonSchemaRegistryMessageSerializer<TMessage>.

KafkaOffsetStoreSettingsBuilder

Builds the KafkaOffsetStoreSettings.

KafkaOffsetStoreSettingsBuilderEntityFrameworkExtensions

Adds the UseEntityFramework<TDbContext>(KafkaOffsetStoreSettingsBuilder) method to the KafkaOffsetStoreSettingsBuilder.

KafkaOffsetStoreSettingsBuilderMemoryExtensions

Adds the UseMemory(KafkaOffsetStoreSettingsBuilder) method to the KafkaOffsetStoreSettingsBuilder.

KafkaOffsetStoreSettingsBuilderPostgreSqlExtensions

Adds the UsePostgreSql(KafkaOffsetStoreSettingsBuilder, string) method to the KafkaOffsetStoreSettingsBuilder.

KafkaOffsetStoreSettingsBuilderSqliteExtensions

Adds the UseSqlite(KafkaOffsetStoreSettingsBuilder, string) method to the KafkaOffsetStoreSettingsBuilder.

MoveMessageErrorPolicyBuilder

Builds the MoveMessageErrorPolicy.

NewtonsoftJsonMessageDeserializerBuilder

Builds the NewtonsoftJsonMessageDeserializer<TMessage> or NewtonsoftJsonMessageDeserializer<TMessage>.

NewtonsoftJsonMessageSerializerBuilder

Builds the NewtonsoftJsonMessageSerializer.

OutboxSettingsBuilder

Builds the OutboxSettings.

OutboxSettingsBuilderEntityFrameworkExtensions

Adds the UseEntityFramework<TDbContext>(OutboxSettingsBuilder) method to the OutboxSettingsBuilder.

OutboxSettingsBuilderMemoryExtensions

Adds the UseMemory(OutboxSettingsBuilder) method to the OutboxSettingsBuilder.

OutboxSettingsBuilderPostgreSqlExtensions

Adds the UsePostgreSql(OutboxSettingsBuilder, string) method to the OutboxSettingsBuilder.

OutboxSettingsBuilderSqliteExtensions

Adds the UseSqlite(OutboxSettingsBuilder, string) method to the OutboxSettingsBuilder.

OutboxWorkerSettingsBuilder

Builds the OutboxWorkerSettings.

PostgreSqlKafkaOffsetStoreSettingsBuilder

Builds the PostgreSqlKafkaOffsetStoreSettings.

PostgreSqlOutboxSettingsBuilder

Builds the PostgreSqlOutboxSettings.

ProducerConfigurationBuilderNewtonsoftExtensions

Adds the SerializeAsJsonUsingNewtonsoft method to the ProducerEndpointConfigurationBuilder<TMessage, TConfiguration, TEndpoint, TBuilder>.

ProducerEndpointConfiguration

The producer configuration.

ProducerEndpointConfigurationBuilderSchemaRegistryExtensions

Adds the SerializeAsAvro<TMessage, TConfiguration, TEndpoint, TBuilder>(ProducerEndpointConfigurationBuilder<TMessage, TConfiguration, TEndpoint, TBuilder>, Action<AvroMessageSerializerBuilder>?), SerializeAsJsonUsingSchemaRegistry<TMessage, TConfiguration, TEndpoint, TBuilder>(ProducerEndpointConfigurationBuilder<TMessage, TConfiguration, TEndpoint, TBuilder>, Action<JsonSchemaRegistryMessageSerializerBuilder>?) and SerializeAsProtobuf<TMessage, TConfiguration, TEndpoint, TBuilder>(ProducerEndpointConfigurationBuilder<TMessage, TConfiguration, TEndpoint, TBuilder>, Action<ProtobufMessageSerializerBuilder>?) methods to the ProducerEndpointConfigurationBuilder<TMessage, TConfiguration, TEndpoint, TBuilder>.

ProducerEndpointConfigurationBuilder<TMessage, TConfiguration, TEndpoint, TBuilder>

Builds the ProducerEndpointConfiguration.

ProducerEndpointConfiguration<TEndpoint>

The producer configuration.

ProtobufMessageDeserializerBuilder

Builds the ProtobufMessageDeserializer<TMessage>.

ProtobufMessageSerializerBuilder

Builds the ProtobufMessageSerializer<TMessage>.

RawMessageDeserializerBuilder

Builds the RawMessageDeserializer<T>.

RetryErrorPolicyBuilder

Builds the RetryErrorPolicy.

SchemaRegistryDeserializerBuilder<TBuilder>

Builds an IMessageDeserializer based on the schema registry.

SchemaRegistrySerializerBuilder<TBuilder>

Builds an IMessageSerializer based on the schema registry.

SkipMessageErrorPolicyBuilder

Builds the SkipMessageErrorPolicy.

SqliteKafkaOffsetStoreSettingsBuilder

Builds the SqliteKafkaOffsetStoreSettings.

SqliteOutboxSettingsBuilder

Builds the SqliteOutboxSettings.

StopConsumerErrorPolicyBuilder

Builds the StopConsumerErrorPolicy.

StringMessageDeserializerBuilder

Builds the StringMessageDeserializer<T>.

StringMessageSerializerBuilder

Builds the StringMessageSerializer.

Interfaces

IBrokerClientsConfigurator

This interface can be implemented to split the producers and consumers configuration across different types. The types implementing IBrokerClientsConfigurator must be registered using AddBrokerClientsConfigurator<TConfigurator>(SilverbackBuilder).

IBrokerClientsInitializer

Initializes the broker clients, producers and consumers.

IErrorPolicyBuilder

Builds the IErrorPolicy.

IErrorPolicyChainBuilder

Builds the IErrorPolicy.

IKafkaOffsetStoreSettingsImplementationBuilder

Builds the specific implementation of the KafkaOffsetStoreSettings.

IMessageSerializationBuilder<TMessage, TBuilder>

Exposes the SerializeUsing(IMessageSerializer) method, allowing to specify the IMessageSerializer to be used to serialize the messages.

IOutboxSettingsImplementationBuilder

Builds the specific implementation of the OutboxSettings.

Enums

BrokerClientConnectionMode

Specifies if and when the message broker has to be automatically connected.