Skip to content

Commit 7813a2d

Browse files
Add ability to specify exchange and exchange_type when using pushRaw() (vyuldashev#420)
1 parent 115040a commit 7813a2d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Queue/RabbitMQQueue.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -824,8 +824,8 @@ protected function publishProperties($queue, array $options = []): array
824824
$attempts = Arr::get($options, 'attempts') ?: 0;
825825

826826
$destination = $this->getRoutingKey($queue);
827-
$exchange = $this->getExchange();
828-
$exchangeType = $this->getExchangeType();
827+
$exchange = $this->getExchange(Arr::get($options, 'exchange'));
828+
$exchangeType = $this->getExchangeType(Arr::get($options, 'exchange_type'));
829829

830830
return [$destination, $exchange, $exchangeType, $attempts];
831831
}

0 commit comments

Comments
 (0)