Member Junction
    Preparing search index...

    Class DatabaseTransportConsumer<TPayload>

    The Database transport's consumer (03 §7, §11). It owns one independent executor for single-step claim, heartbeat and settle calls (never running statements on the shared source or opening transactions on this.owned, which may serve concurrent in-flight deliveries when Concurrency > 1). Multi-statement ExhaustionBehavior === 'Discard' transitions run atomically on a short-lived independent transaction via RunInWorkQueueTransaction(this.source, ...).

    Type Parameters

    Implements

    Index

    Constructors

    Methods