Interface IOutboxStore
Contract for persisting outgoing messages before they are sent to the broker.
Each provider (e.g. MassTransit, Zamin) will supply its own implementation.
Assembly: Chapar.Core.dll
Syntax
public interface IOutboxStore
Methods
|
Edit this page
View Source
GetUnprocessedMessagesAsync(CancellationToken)
Retrieves all unprocessed outbox messages. The order should be consistent
to preserve causality (usually by OccurredOn).
Declaration
Task<IReadOnlyList<OutboxMessage>> GetUnprocessedMessagesAsync(CancellationToken cancellationToken = default)
Parameters
Returns
|
Edit this page
View Source
GetUnprocessedMessagesCountAsync(CancellationToken)
Gets the total count of unprocessed outbox messages.
Declaration
Task<int> GetUnprocessedMessagesCountAsync(CancellationToken cancellationToken = default)
Parameters
Returns
|
Edit this page
View Source
MarkAsProcessedAsync(Guid, CancellationToken)
Marks an outbox message as successfully published.
Declaration
Task MarkAsProcessedAsync(Guid messageId, CancellationToken cancellationToken = default)
Parameters
Returns
|
Edit this page
View Source
SaveAsync(OutboxMessage, CancellationToken)
Saves a single outbox message in the same transaction as the business data.
Declaration
Task SaveAsync(OutboxMessage message, CancellationToken cancellationToken = default)
Parameters
Returns