Class OutboxOptions
Options that control how Stratara.Outbox.RabbitMQ.Outbox.OutboxWorker drains the outbox table.
Bound from the Outbox configuration section (see SectionName).
[ExcludeFromCodeCoverage]
public sealed class OutboxOptions- Inheritance
-
OutboxOptions
- Inherited Members
- Extension Methods
Fields
SectionName
Configuration section name ("Outbox") used to bind these options.
public const string SectionName = "Outbox"Field Value
Properties
BatchSize
Maximum number of outbox entries fetched per drain cycle and entry kind. Defaults to 10 000. A cycle takes one batch of commands and one batch of event bundles and ends; entries the bus did not accept stay in the table and are retried on the next interval. Together with PollingIntervalSeconds this value therefore sets the drain rate — 20 000 entries a minute with the defaults. Raise it, or shorten the polling interval, to work off a large backlog faster.
public int BatchSize { get; set; }Property Value
DurableBundles
Whether an event bundle is written to the outbox table in the same transaction that commits its events, published after the commit, and removed once the bus has accepted it. Defaults to false, the bus-first path: the bundle reaches the table only if the bus refuses it, and a process that ends between the commit and the publish loses the bundle for every subscription. With true a committed fact is in the table until the bus has it, at the cost of one insert per save and one delete per accepted bundle. The store must let the dispatcher choose the entry's identity: the framework's outbox repository does, a consumer-supplied one has to implement the identity-taking overload.
public bool DurableBundles { get; set; }Property Value
LockLeaseSeconds
Lease (in seconds) requested when the worker acquires the outbox-drain lock. Should be
comfortably longer than the worst-case drain duration (batch size × per-publish latency)
so the lock does not expire mid-cycle. Defaults to 60 seconds. Has no effect when the
no-op NullOutboxLock is registered.
public int LockLeaseSeconds { get; set; }Property Value
PollingIntervalSeconds
Interval (in seconds) between two outbox drain attempts. The worker polls the outbox table, publishes any unsent entries, sleeps for this interval, and repeats. Defaults to 30 seconds.
public int PollingIntervalSeconds { get; set; }