fix(RabbitMQQueue): handle ack error (#137)

AGScheduler · May 29, 2024 · 89ed6fd · 89ed6fd
1 parent e187bf2
commit 89ed6fd
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/queues/rabbitmq.go b/queues/rabbitmq.go
@@ -159,7 +159,12 @@ func (q *RabbitMQQueue) handleMessage(ctx context.Context) {
 			return
 		case d := <-msgs:
 			q.jobC <- d.Body
-			d.Ack(false)
+			err := d.Ack(false)
+			if err != nil {
+				slog.Error(fmt.Sprintf("RabbitMQQueue ack error: `%s`", err))
+				time.Sleep(1 * time.Second)
+				continue
+			}
 		}
 	}
 }