Interface IEventBundleOutboxDispatcher

Namespace

Stratara.Abstractions.Outbox

Assembly

Stratara.Abstractions.dll

Enqueues event bundles produced by the event-source on save for projection and saga workers to consume. Implementations first try direct publish and fall back to the outbox table if the bus is unreachable.

public interface IEventBundleOutboxDispatcher

Extension Methods

FieldChangedEventExtensions.ApplyPropertyChanged<TAggregate>(TAggregate, FieldChangedEvent<TAggregate>)

EventStream.ApplyEvents(object, IReadOnlyList<IEvent>)

Methods

EnqueueEventBundleAsync(EventBundle, CancellationToken)

Enqueue eventBundle for asynchronous dispatch.

Task EnqueueEventBundleAsync(EventBundle eventBundle, CancellationToken cancellationToken = default)

Parameters

eventBundle EventBundle

cancellationToken CancellationToken

Returns

Task

EnqueueOutboxEntriesAsync(IEnumerable<OutboxEntry>, CancellationToken)

Drain previously-persisted outboxEntries by attempting to publish each one and deleting on success. Used by the outbox worker.

Task EnqueueOutboxEntriesAsync(IEnumerable<OutboxEntry> outboxEntries, CancellationToken cancellationToken = default)

Parameters

outboxEntries IEnumerable<OutboxEntry>

cancellationToken CancellationToken

Returns

Task