Class ZaminOutboxStore

Implements IOutboxStore and ICleanupStore using Zamin's native OutBoxEventItem table.

Inheritance
object
ZaminOutboxStore
Implements
Inherited Members
Namespace: Chapar.Zamin.Outbox.Outbox
Assembly: Chapar.Zamin.Outbox.dll
Syntax
public sealed class ZaminOutboxStore : IOutboxStore, ICleanupStore

Constructors

| Edit this page View Source

ZaminOutboxStore(BaseOutboxCommandDbContext)

Declaration
public ZaminOutboxStore(BaseOutboxCommandDbContext dbContext)
Parameters
Type Name Description
BaseOutboxCommandDbContext dbContext

Methods

| Edit this page View Source

DeleteProcessedAsync(DateTime, CancellationToken)

Deletes all processed records older than the specified date. Returns the number of deleted records.

Declaration
public Task<int> DeleteProcessedAsync(DateTime olderThan, CancellationToken cancellationToken = default)
Parameters
Type Name Description
DateTime olderThan

Cutoff date; records processed before this will be deleted.
CancellationToken cancellationToken

Cancellation token.
Returns
Type Description
Task<int>

Number of deleted records.
| Edit this page View Source

GetUnprocessedMessagesAsync(CancellationToken)

Retrieves all unprocessed outbox messages. The order should be consistent to preserve causality (usually by OccurredOn).

Declaration
public Task<IReadOnlyList<OutboxMessage>> GetUnprocessedMessagesAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<IReadOnlyList<OutboxMessage>>
| Edit this page View Source

GetUnprocessedMessagesCountAsync(CancellationToken)

Gets the total count of unprocessed outbox messages.

Declaration
public Task<int> GetUnprocessedMessagesCountAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<int>
| Edit this page View Source

MarkAsProcessedAsync(Guid, CancellationToken)

Marks an outbox message as successfully published.

Declaration
public Task MarkAsProcessedAsync(Guid messageId, CancellationToken cancellationToken = default)
Parameters
Type Name Description
Guid messageId
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

SaveAsync(OutboxMessage, CancellationToken)

Saves a single outbox message in the same transaction as the business data.

Declaration
public Task SaveAsync(OutboxMessage message, CancellationToken cancellationToken = default)
Parameters
Type Name Description
OutboxMessage message
CancellationToken cancellationToken
Returns
Type Description
Task

Implements