Interface IEventDispatchStore
Namespace: Cephalon.Eventing.Services
Assembly: Cephalon.Eventing.dll
Reads pending staged events and applies durable dispatch outcomes for the active eventing runtime.
public interface IEventDispatchStoreRemarks
Section titled “Remarks”This contract stays runtime-neutral on purpose. It does not claim broker ownership, delivery guarantees, or concurrency semantics beyond what the active outbox implementation actually provides.
Properties
Section titled “Properties”OutboxIds
Section titled “ OutboxIds”Gets the outbox identifiers explicitly owned by the dispatch store.
IReadOnlyList<string> OutboxIds { get; }Property Value
Section titled “Property Value”Methods
Section titled “Methods”ApplyReportAsync(EventDispatchExecutionReport, CancellationToken)
Section titled “ ApplyReportAsync(EventDispatchExecutionReport, CancellationToken)”Applies one durable dispatch outcome to the active staged-event store.
ValueTask ApplyReportAsync(EventDispatchExecutionReport report, CancellationToken cancellationToken = default)Parameters
Section titled “Parameters”report EventDispatchExecutionReport
The dispatch observation to apply.
cancellationToken CancellationToken
The token that cancels the operation.
Returns
Section titled “Returns”A task that completes when the durable store has applied the dispatch observation.
ReadPendingAsync(int, CancellationToken)
Section titled “ ReadPendingAsync(int, CancellationToken)”Reads pending staged events that are eligible for dispatch.
ValueTask<IReadOnlyList<EventDispatchItem>> ReadPendingAsync(int maximumCount, CancellationToken cancellationToken = default)Parameters
Section titled “Parameters”maximumCount int
The maximum number of staged events to read.
cancellationToken CancellationToken
The token that cancels the operation.
Returns
Section titled “Returns”ValueTask<IReadOnlyList<EventDispatchItem>>
The pending staged events that are currently eligible for dispatch.