Class OutboxDispatcher<TPayload>

Pluggable dispatch loop helper for the Transactional Outbox pattern. Combines an IOutboxStore<TPayload> with an IOutboxDispatcher<TPayload> to provide a reusable relay loop.

public sealed class OutboxDispatcher<TPayload>

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

Creates an outbox dispatcher bound to the given store and dispatcher.

public OutboxDispatcher(IOutboxStore<TPayload> store, IOutboxDispatcher<TPayload> dispatcher)

Drains all pending outbox records by dispatching each through the configured dispatcher. Returns the number of records successfully dispatched.

public ValueTask<int> DrainAsync(CancellationToken cancellationToken = default)

Continuously drains pending outbox records until cancellationToken is cancelled, waiting pollInterval between each drain cycle.

public ValueTask RunAsync(TimeSpan pollInterval, CancellationToken cancellationToken = default)