fix:

bee-org · Mar 10, 2023 · c6f9832 · c6f9832
1 parent 2499f30
commit c6f9832
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/broker/amqp/amqp.go b/broker/amqp/amqp.go
@@ -172,8 +172,11 @@ func (b *Broker) watch(ctx context.Context) {
 				<-seat
 				wg.Add(1)
 				go func() {
-					_ = b.process(ctx, data)
-					_ = data.Ack(false)
+					if err := b.process(ctx, data); err != nil {
+						_ = data.Nack(false, true)
+					} else {
+						_ = data.Ack(false)
+					}
 					wg.Done()
 					seat <- struct{}{}
 				}()