From e7f9f638bd1995adc75f838501655e1ab3826f15 Mon Sep 17 00:00:00 2001 From: Evstigneev Denis Date: Wed, 10 Dec 2025 15:20:14 +0300 Subject: [PATCH] add opt gracefultimeout broker --- broker/options.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/broker/options.go b/broker/options.go index 2c6a58c0..c1f3588c 100644 --- a/broker/options.go +++ b/broker/options.go @@ -80,6 +80,12 @@ func Context(ctx context.Context) Option { } } +func GracefulTimeout(t time.Duration) Option { + return func(o *Options) { + o.GracefulTimeout = t + } +} + // ContentType used by default if not specified func ContentType(ct string) Option { return func(o *Options) {