Class DbOffsetStore

Used by the OffsetStoreExactlyOnceStrategy to keep track of the last processed offsets and guarantee that each message is processed only once.

An IDbContext is used to store the offsets into the database.

Inheritance
System.Object
RepositoryBase<StoredOffset>
DbOffsetStore
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Inbound.ExactlyOnce.Repositories
Assembly: Silverback.Integration.dll
Syntax
public sealed class DbOffsetStore : RepositoryBase<StoredOffset>, IOffsetStore, ITransactional

Constructors

| Improve this doc View source

DbOffsetStore(IDbContext)

Initializes a new instance of the DbOffsetStore class.

Declaration
public DbOffsetStore(IDbContext dbContext)
Parameters
Type Name Description
IDbContext dbContext

The IDbContext to use as storage.

Methods

| Improve this doc View source

CommitAsync()

Declaration
public async Task CommitAsync()
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

GetLatestValueAsync(String, IConsumerEndpoint)

Declaration
public async Task<IBrokerMessageOffset> GetLatestValueAsync(string offsetKey, IConsumerEndpoint endpoint)
Parameters
Type Name Description
System.String offsetKey
IConsumerEndpoint endpoint
Returns
Type Description
System.Threading.Tasks.Task<IBrokerMessageOffset>
| Improve this doc View source

RollbackAsync()

Declaration
public Task RollbackAsync()
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

StoreAsync(IBrokerMessageOffset, IConsumerEndpoint)

Declaration
public async Task StoreAsync(IBrokerMessageOffset offset, IConsumerEndpoint endpoint)
Parameters
Type Name Description
IBrokerMessageOffset offset
IConsumerEndpoint endpoint
Returns
Type Description
System.Threading.Tasks.Task

Implements