Skip to content

Commit 3aacaa7

Browse files
committed
1 parent a404ea9 commit 3aacaa7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public function push($job, $data = '', $queue = null)
6666
public function pushRaw($payload, $queue = null, array $options = [])
6767
{
6868
$queue = $this->getQueueName($queue);
69-
$exchange = $this->configExchange['name'] ?:$queue;
69+
//$exchange = $this->configExchange['name'] ?:$queue;
7070
$this->declareQueue($queue);
7171
if (isset($options['delay'])) {
7272
$queue = $this->declareDelayedQueue($queue, $options['delay']);
@@ -79,7 +79,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
7979
]);
8080

8181
// push task to a queue
82-
$this->channel->basic_publish($message, $exchange, $queue);
82+
$this->channel->basic_publish($message, $queue, $queue);
8383

8484
return true;
8585
}

0 commit comments

Comments
 (0)