[#69]: fix: add queue name to received job

roadrunner-server · May 18, 2023 · 8299ddc · 8299ddc
2 parents 39fe40f + 4de9057
commit 8299ddc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/amqpjobs/driver.go b/amqpjobs/driver.go
@@ -340,7 +340,7 @@ func (d *Driver) Push(ctx context.Context, job jobs.Job) error {
 	ctx, span := trace.SpanFromContext(ctx).TracerProvider().Tracer(tracerName).Start(ctx, "amqp_push")
 	defer span.End()
 
-	if d.routingKey == "" {
+	if d.routingKey == "" && d.exchangeType != "fanout" {
 		return errors.Str("empty routing key, consider adding the routing key name to the AMQP configuration")
 	}
 

diff --git a/amqpjobs/item.go b/amqpjobs/item.go
@@ -275,6 +275,7 @@ func (d *Driver) unpack(deliv amqp.Delivery) (*Item, error) {
 			multipleAsk: d.multipleAck,
 			requeue:     d.requeueOnFail,
 			requeueFn:   d.handleItem,
+			Queue:       d.queue,
 		},
 	}