[L5][Beanstalkd] Dispatch command onto specific tube

Hi, When we dispatch a command, the command bus checks if the command is queue-able. In case it ShoulBeQueued it calls the dispatchToQueue method.

If we define a method named as queue inside our queued command the dispatchToQueue will prefer this method to use for the queuing of the Command.

Here is an example that you can use as a reference:

<?php namespace App\Commands;

use App\Commands\Command;

use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldBeQueued;

class QueuedCommand extends Command implements ShouldBeQueued {

    use InteractsWithQueue, SerializesModels;


    public $message;
    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct($message)
    {
        $this->message = $message;
    }

    public function queue($queue, $command)
    {

        $queue->pushOn('my_queue',$command);

    }
}

Now your command will be queued on 'my_queue`. you can work it out using the:

./artisan queue:work --queue="my_queue"

I have tested it using Beanstalkd driver and works perfectly :)

I hope this will help you. Usman.

I figured it would be something like that. Thanks @usman !!

@thsteinmetz No problem :)

Cheers for this @usman, just what I was looking for!

@usman - thank you so much for that wonder clear example. This should have been in the docs I think, but anyway, it works perfectly!

I tried to implement this on a command which has a separate handler on L/5.0

Any reason why this method won't execute a pushOn tube?

@usman

UPDATE ** DISREGARD MY LAST COMMENT... YOU CAN JUST USE Queue::laterOn( $tube, $time, $job );

Laravel 5.1 Docs now have a much clearer and simpler example for this:

Specifying The Queue For A Job

You may also specify the queue a job should be sent to.

By pushing jobs to different queues, you may "categorize" your queued jobs, and even prioritize how many workers you assign to various queues. This does not push jobs to different queue "connections" as defined by your queue configuration file, but only to specific queues within a single connection. To specify the queue, use the onQueue method on the job instance. The onQueue method is provided by the base App\Jobs\Job class included with Laravel:

<?php

namespace App\Http\Controllers;

use App\User;
use Illuminate\Http\Request;
use App\Jobs\SendReminderEmail;
use App\Http\Controllers\Controller;

class UserController extends Controller
{
    /**
     * Send a reminder e-mail to a given user.
     *
     * @param  Request  $request
     * @param  int  $id
     * @return Response
     */
    public function sendReminderEmail(Request $request, $id)
    {
        $user = User::findOrFail($id);

        $job = (new SendReminderEmail($user))->onQueue('emails');

        $this->dispatch($job);
    }
}

An update for Laravel 5.1:

    public function queue($queue, $command, $data)
    {
        $queue->pushOn('your-queue', $command, $data);
    }