From 4982e2cf59df2a5fead53647b8770bda71ff2f36 Mon Sep 17 00:00:00 2001 From: Rajesh K Date: Sat, 29 Jan 2022 16:24:40 +0530 Subject: [PATCH] QueueManager::push() not respecting custom queue name --- src/QueueManager.php | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/QueueManager.php b/src/QueueManager.php index bc87b56..e67402c 100644 --- a/src/QueueManager.php +++ b/src/QueueManager.php @@ -213,7 +213,15 @@ public static function push($callable, array $args = [], array $options = []): v $name = $options['config']; $config = static::getConfig($name); - $queue = $config['queue'] ?? 'default'; + if (!empty($options['queue'])) { + $queue = $options['queue']; + } + elseif (!empty($config['queue'])) { + $queue = $config['queue']; + } + else { + $queue = 'default'; + } $message = new ClientMessage([ 'queue' => $queue,