Interface DeliveryExecutionOptions<TPayload>

interface DeliveryExecutionOptions<TPayload extends WorkJson = WorkJson> {
    CancelDrainMs?: number;
    Consumer: ITransportConsumer<TPayload>;
    Delivery: ReceivedDelivery<TPayload>;
    HandlerFactory: () => WorkHandler<TPayload>;
    LeaseExpiryGraceMs?: number;
    Log: WorkLogger;
    Now?: () => number;
    Policy: SubscriptionPolicy;
    Random?: () => number;
}

Type Parameters

TPayload extends WorkJson = WorkJson

Index

Properties

CancelDrainMs? Consumer Delivery HandlerFactory LeaseExpiryGraceMs? Log Now? Policy Random?

Properties

`Optional`CancelDrainMs

CancelDrainMs?: number

Defaults to DEFAULT_CANCEL_DRAIN_MS; ConsumerRuntime passes its ShutdownDrainMs.

Consumer

Consumer: ITransportConsumer<TPayload>

Delivery

Delivery: ReceivedDelivery<TPayload>

HandlerFactory

HandlerFactory: () => WorkHandler<TPayload>

`Optional`LeaseExpiryGraceMs

LeaseExpiryGraceMs?: number

Defaults to LEASE_EXPIRY_GRACE_MS.

Log

Log: WorkLogger

`Optional`Now

Now?: () => number

Policy

Policy: SubscriptionPolicy

`Optional`Random

Random?: () => number