fix: remove ack from nats core

snapp-incubator · Oct 6, 2024 · 5b4a7b0 · 5b4a7b0
1 parent 85d934d
commit 5b4a7b0
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/internal/client/jetstream.go b/internal/client/jetstream.go
@@ -385,10 +385,6 @@ func (client *Client) messageHandlerCoreFactory() (nats.MsgHandler, <-chan *Mess
 			Subject: msg.Subject,
 			Data:    msg.Data,
 		}
-
-		if err := msg.Ack(); err != nil {
-			client.logger.Error("Failed to acknowledge the message", zap.Error(err))
-		}
 	}, ch
 }