egor3f/rssalchemy
1
0
Fork 0
Code Actions Packages Releases Wiki Activity

dont discard already accepted task

Browse Source
This commit is contained in:
Egor Aristov 2025-01-31 12:29:13 +03:00
parent 10792716e4
commit a9e75cff95
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/adapters/natsadapter/natsadapter.go
View File

@ -151,10 +151,7 @@ func (na *NatsAdapter) ConsumeQueue(
} }
if taskErr != nil { if taskErr != nil {
log.Errorf("taskFunc seq=%d error, discarding task: %v", seq, taskErr) log.Errorf("taskFunc seq=%d error: %v", seq, taskErr)
if err := msg.Term(); err != nil {
log.Errorf("nak %d: %v", seq, err)
}
return return
} }