terminate task in case of panic

2025-01-25 20:08:43 +03:00 · 2025-01-25 20:08:43 +03:00 · 8e7e1d1cd6
commit 8e7e1d1cd6
parent f78345ab14
1 changed files with 3 additions and 0 deletions
--- a/internal/adapters/natsadapter/natsadapter.go
+++ b/internal/adapters/natsadapter/natsadapter.go
@ -139,6 +139,9 @@ func (na *NatsAdapter) ConsumeQueue(
 		defer func() {
 			if err := recover(); err != nil {
 				log.Errorf("recovered panic from consumer: %v", err)
+				if err := msg.Term(); err != nil {
+					log.Errorf("term in recover: %v", err)
+				}
 			}
 		}()
 		cacheKey, resultPayload, taskErr := taskFunc(msg.Data())