From a9e75cff9577bce731db7bfa005133b5526dfe5d Mon Sep 17 00:00:00 2001
From: Egor Aristov <ef@efprojects.com>
Date: Fri, 31 Jan 2025 12:29:13 +0300
Subject: [PATCH] dont discard already accepted task

---
 internal/adapters/natsadapter/natsadapter.go | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/internal/adapters/natsadapter/natsadapter.go b/internal/adapters/natsadapter/natsadapter.go
index d70eb46..7b8ce6a 100644
--- a/internal/adapters/natsadapter/natsadapter.go
+++ b/internal/adapters/natsadapter/natsadapter.go
@@ -151,10 +151,7 @@ func (na *NatsAdapter) ConsumeQueue(
 		}
 
 		if taskErr != nil {
-			log.Errorf("taskFunc seq=%d error, discarding task: %v", seq, taskErr)
-			if err := msg.Term(); err != nil {
-				log.Errorf("nak %d: %v", seq, err)
-			}
+			log.Errorf("taskFunc seq=%d error: %v", seq, taskErr)
 			return
 		}