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 {