diff --git a/packages/notifications/src/BroadcastNotification.php b/packages/notifications/src/BroadcastNotification.php index 5a0a50f201..74ac42cc58 100644 --- a/packages/notifications/src/BroadcastNotification.php +++ b/packages/notifications/src/BroadcastNotification.php @@ -33,6 +33,8 @@ class BroadcastNotification extends BaseNotification implements ShouldQueue */ public function toBroadcast($notifiable): BroadcastMessage { - return new BroadcastMessage($this->data); + return (new BroadcastMessage($this->data)) + ->onConnection($this->connection) + ->onQueue($this->queue); } }