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,