Namespace Silverback.Messaging.Inbound.ExactlyOnce.Repositories

Classes

DbInboundLog

Used by the LogExactlyOnceStrategy to keep track of each processed message and guarantee that each one is processed only once.

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

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.

InMemoryInboundLog

Used by the LogExactlyOnceStrategy to keep track of each processed message and guarantee that each one is processed only once.

The log is simply persisted in memory.

InMemoryOffsetStore

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

The log is simply persisted in memory.

Interfaces

IInboundLog

Used by the LogExactlyOnceStrategy to keep track of each processed message and guarantee that each one is processed only once.

IOffsetStore

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