Laravel 11 / Foundation\Bus PendingDispatch::onConnection()

Introduction to the onConnection feature in PendingDispatch in Laravel 11

Hello! Today, we want to discuss an interesting feature in Laravel 11 called onConnection. If you are also among Laravel developers, you are probably familiar with the concept of queues. This capability allows you to specify which connection a task must be executed on. This feature helps us manage different tasks across various connections and better control them.

Imagine you have several connections to queues; for example, one for a data queue, another for Redis, and yet another for Beanstalk. With the use of this feature, you can easily determine which task should be executed on which connection. This capability can assist in effectively managing tasks and increasing the functionality of your application.

Additionally, this capability helps development teams execute tasks that may need to run on specific connections more easily. For instance, if you have a task that needs to use a specific data queue, by defining the correct connection, you can ensure that your task is executed in the best possible state.

Now let's look at a practical example of using this capability so you can better understand how to use it in your projects. We'll create a simple task to send an email and execute it on a specific connection using onConnection.

Example code for using onConnection in Laravel 11

use Illuminate\Bus\PendingDispatch;

// When you want to dispatch the task to send an email
PendingDispatch::dispatch(new SendEmailJob($user))
    ->onConnection('redis');

Line by line explanation of the code

use Illuminate\Bus\PendingDispatch;
This line allows us to import the PendingDispatch class, which is necessary for sending tasks.

PendingDispatch::dispatch(new SendEmailJob($user))
This line creates a new task called SendEmailJob for the user being used that we are going to dispatch.

->onConnection('redis')
With this part of the code, we specify that this task should be executed on the redis connection. Thus, we can ensure that our task runs in the appropriate environment.