Class BrokerOptionsBuilderAddOffsetStoreExtensions
Adds the AddOffsetStore
and related methods to the IBrokerOptionsBuilder.
Inherited Members
Namespace: Microsoft.Extensions.DependencyInjection
Assembly: Silverback.Integration.dll
Syntax
public static class BrokerOptionsBuilderAddOffsetStoreExtensions
Methods
| Improve this doc View sourceAddInMemoryOffsetStore(IBrokerOptionsBuilder)
Adds the necessary services to enable the OffsetStoreExactlyOnceStrategy storing the offsets in memory.
The OffsetStoreExactlyOnceStrategy stores uses an IOffsetStore to keep track of the latest processed offsets and guarantee that each message is processed only once.
Declaration
public static IBrokerOptionsBuilder AddInMemoryOffsetStore(this IBrokerOptionsBuilder brokerOptionsBuilder)
Parameters
Type | Name | Description |
---|---|---|
IBrokerOptionsBuilder | brokerOptionsBuilder | The IBrokerOptionsBuilder that references the IServiceCollection to add the services to. |
Returns
Type | Description |
---|---|
IBrokerOptionsBuilder | The IBrokerOptionsBuilder so that additional calls can be chained. |
AddOffsetStoreDatabaseTable(IBrokerOptionsBuilder)
Adds the necessary services to enable the OffsetStoreExactlyOnceStrategy using a database table as store.
The OffsetStoreExactlyOnceStrategy stores uses an IOffsetStore to keep track of the latest processed offsets and guarantee that each message is processed only once.
Declaration
public static IBrokerOptionsBuilder AddOffsetStoreDatabaseTable(this IBrokerOptionsBuilder brokerOptionsBuilder)
Parameters
Type | Name | Description |
---|---|---|
IBrokerOptionsBuilder | brokerOptionsBuilder | The IBrokerOptionsBuilder that references the IServiceCollection to add the services to. |
Returns
Type | Description |
---|---|
IBrokerOptionsBuilder | The IBrokerOptionsBuilder so that additional calls can be chained. |
AddOffsetStore<TOffsetStore>(IBrokerOptionsBuilder)
Adds the necessary services to enable the OffsetStoreExactlyOnceStrategy.
The OffsetStoreExactlyOnceStrategy stores uses an IOffsetStore to keep track of the latest processed offsets and guarantee that each message is processed only once.
Declaration
public static IBrokerOptionsBuilder AddOffsetStore<TOffsetStore>(this IBrokerOptionsBuilder brokerOptionsBuilder) where TOffsetStore : class, IOffsetStore
Parameters
Type | Name | Description |
---|---|---|
IBrokerOptionsBuilder | brokerOptionsBuilder | The IBrokerOptionsBuilder that references the IServiceCollection to add the services to. |
Returns
Type | Description |
---|---|
IBrokerOptionsBuilder | The IBrokerOptionsBuilder so that additional calls can be chained. |
Type Parameters
Name | Description |
---|---|
TOffsetStore | The type of the IOffsetStore to be used. |