From 0252addf05b6c0c8e0a474447b669fb219c2578b Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Mon, 31 Aug 2020 16:51:49 +0300 Subject: [PATCH] broker: resurrect DisableAutoAck Signed-off-by: Vasiliy Tolstov --- broker/options.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/broker/options.go b/broker/options.go index 7b15828e..4f87c56f 100644 --- a/broker/options.go +++ b/broker/options.go @@ -97,6 +97,12 @@ func Codec(c codec.Marshaler) Option { } } +func DisableAutoAck() SubscribeOption { + return func(o *SubscribeOptions) { + o.AutoAck = false + } +} + // SubscribeAutoAck will disable auto acking of messages // after they have been handled. func SubscribeAutoAck(b bool) SubscribeOption {