Ack when AutoAckDisabled is off

Signed-off-by: shivam <shivamkm07@gmail.com>
eclipse · Oct 18, 2022 · 2518954 · 2518954
1 parent 35f45ad
commit 2518954
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/router.go b/router.go
@@ -186,7 +186,7 @@ func (r *router) matchAndDispatch(messages <-chan *packets.PublishPacket, order
 						wg.Add(1)
 						go func() {
 							hd(client, m)
-							if client.options.AutoAckDisabled {
+							if !client.options.AutoAckDisabled {
 								m.Ack()
 							}
 							wg.Done()
@@ -203,7 +203,7 @@ func (r *router) matchAndDispatch(messages <-chan *packets.PublishPacket, order
 						wg.Add(1)
 						go func() {
 							r.defaultHandler(client, m)
-							if client.options.AutoAckDisabled {
+							if !client.options.AutoAckDisabled {
 								m.Ack()
 							}
 							wg.Done()
@@ -216,7 +216,7 @@ func (r *router) matchAndDispatch(messages <-chan *packets.PublishPacket, order
 			r.RUnlock()
 			for _, handler := range handlers {
 				handler(client, m)
-				if client.options.AutoAckDisabled {
+				if !client.options.AutoAckDisabled {
 					m.Ack()
 				}
 			}