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.