Property ConsumerDrainOnDisposeTimeout

Namespace

NATS.Client.Core

Assembly

NATS.Client.Core.dll

ConsumerDrainOnDisposeTimeout

When set, JetStream consumer/fetch dispose waits up to this timeout for the user's consume loop to finish acking buffered messages before returning. (default: null, no wait)

public TimeSpan? ConsumerDrainOnDisposeTimeout { get; init; }

Property Value

TimeSpan?

Remarks

Only effective when DrainSubscriptionsOnDispose is also true. Without this wait, messages already delivered into the consumer channel but not yet yielded by the user loop are dropped on dispose and remain NumAckPending until AckWait expires.