From 2478a76e0c997e309f14854e159c96fcea0a6008 Mon Sep 17 00:00:00 2001 From: Egor Aristov Date: Sat, 25 Jan 2025 20:08:43 +0300 Subject: [PATCH] terminate task in case of panic --- internal/adapters/natsadapter/natsadapter.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/adapters/natsadapter/natsadapter.go b/internal/adapters/natsadapter/natsadapter.go index d53e811..d70eb46 100644 --- 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())