[Messenger] send using the routing_key for AMQP transport
This commit is contained in:
parent
3dda3cc5b3
commit
666d2d962b
@ -98,7 +98,7 @@ class Connection
|
||||
$this->setup();
|
||||
}
|
||||
|
||||
$this->exchange()->publish($body, null, AMQP_NOPARAM, array('headers' => $headers));
|
||||
$this->exchange()->publish($body, $this->queueConfiguration['routing_key'] ?? null, AMQP_NOPARAM, array('headers' => $headers));
|
||||
}
|
||||
|
||||
/**
|
||||
|
Reference in New Issue
Block a user