ingest: nack message

neicnordic · Nov 12, 2024 · 01f742d · 01f742d
1 parent 7e1bfe8
commit 01f742d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/sda/cmd/ingest/ingest.go b/sda/cmd/ingest/ingest.go
@@ -397,6 +397,9 @@ func main() {
 						err = db.SetKeyHash(keyhash, fileID)
 						if err != nil {
 							log.Errorf("Key hash %s could not be set for fileID %s: (%s)", keyhash, fileID, err.Error())
+							if err = delivered.Nack(false, true); err != nil {
+								log.Errorf("Failed to Nack message, reason: (%s)", err.Error())
+							}
 
 							continue mainWorkLoop
 						}