support viaQueues method

laravel · May 11, 2020 · e97d17c · bholub · May 13, 2020 · e97d17c
1 parent 880b637
commit e97d17c
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/Illuminate/Notifications/NotificationSender.php b/src/Illuminate/Notifications/NotificationSender.php
@@ -190,10 +190,16 @@ protected function queueNotification($notifiables, $notification)
                     $notification->locale = $this->locale;
                 }
 
+                $queue = $notification->queue;
+
+                if (method_exists($notification, 'viaQueues')) {
+                    $queue = $notification->viaQueues()[$channel] ?? null;
+                }
+
                 $this->bus->dispatch(
                     (new SendQueuedNotifications($notifiable, $notification, [$channel]))
                             ->onConnection($notification->connection)
-                            ->onQueue($notification->onQueues[$channel] ?? $notification->queue)
+                            ->onQueue($queue)
                             ->delay($notification->delay)
                             ->through(
                                 array_merge(