pkg/event: Set mandatory field in simple producer

livepeer · Dec 7, 2022 · f83335c · f83335c
1 parent c74a21c
commit f83335c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/event/simple_producers.go b/pkg/event/simple_producers.go
@@ -26,7 +26,7 @@ func NewAMQPExchangeProducer(ctx context.Context, uri, exchange, keyNs string) (
 		if keyNs != "" {
 			key = keyNs + "." + key
 		}
-		return producer.Publish(ctx, AMQPMessage{exchange, key, body, persistent, nil, true})
+		return producer.Publish(ctx, AMQPMessage{exchange, key, body, persistent, false, nil, true})
 	}), nil
 }
 
@@ -50,7 +50,7 @@ func NewAMQPQueueProducer(ctx context.Context, uri, queue string) (SimpleProduce
 		if key != "" {
 			return errors.New("when sending directly to a queue, key must always be empty")
 		}
-		return producer.Publish(ctx, AMQPMessage{"", queue, body, persistent, nil, true})
+		return producer.Publish(ctx, AMQPMessage{"", queue, body, persistent, false, nil, true})
 	}), nil
 }