Async Queues In Laravel

Question

I'm trying to implement Queuing, but the result is not async And I have Applied the following

config/queue.php
'default' => env('QUEUE_DRIVER', 'database'),
    'connections' => [

    'sync' => [
        'driver' => 'sync',
    ],

    'database' => [
        'driver' => 'database',
        'table' => 'jobs',
        'queue' => 'default',
        'expire' => 60,
    ],
   ]

and then applied the following commands php artisan queue:table php artisan migrate

and then run

php artisan queue:listen

and here is the functionality

SomethingController.php
   $model1 = new \App\Model1;
public function store(){
     Log::debug('before dispatch');
     $this->dispatch(new SendGiftCommand($model1));
     Log::debug('before dispatch');
     return true;
}



SendGiftCommand.php
{
    Log::debug('handle');
    SendGift::SendGiftAgedBased($this->model1);
    sleep(4);
    Log::debug('SendGiftCommand end');
}
SendGift.php
public static function SendGiftAgedBased(Model1 $model1){
  Log::debug('inside SendGiftAgedBased');
}

even the process has worked but its not async, and it waits for the command to finish to return the response in the controller

And I git the Logs in this order

 [2015-12-09 16:28:42] local.DEBUG: before dispatch  
 [2015-12-09 16:28:42] local.DEBUG: handle  
 [2015-12-09 16:28:42] local.DEBUG: inside SendGiftAgedBased   
 [2015-12-09 16:28:46] local.DEBUG: SendGiftCommand end  
 [2015-12-09 16:28:46] local.DEBUG: after dispatch

should it be working on Localhost ?

Jocelyn · Accepted Answer · 2016-02-01 18:39:18Z

12

I had the same problem with jobs not being asynchronous and this worked for me :

Edit .env and change the QUEUE_DRIVER setting from sync to database (editing config/queue.php wasn't enough)
Restart your processes

answered Feb 1, 2016 at 18:39

Jocelyn

1,29412 silver badges20 bronze badges

Sign up to request clarification or add additional context in comments.

3 Comments

Ben Wilson Over a year ago

This helped me immensely -- no idea why this isn't in the documentation

Ben Wilson Over a year ago

Also, remember to run php artisan config:clear afterward

Saifur Rahman Mohsin Over a year ago

Is this database driver really asynchronous? I tried running it but doesn't look like it's running async operations. Every job is sequential and not in parallel.

jedrzej.kurylo · Accepted Answer · 2015-12-09 15:14:42Z

2

In order for the job to be queued, the job class needs to implement Illuminate\Contracts\Queue\ShouldQueue interface - make sure it's true for your class.

You can find more info on queuing jobs here: http://laravel.com/docs/5.1/queues#writing-job-classes

answered Dec 9, 2015 at 15:14

jedrzej.kurylo

41.1k10 gold badges108 silver badges112 bronze badges

5 Comments

user2099451 Over a year ago

It already implemented ShouldQueue , but should it act async on localhost ?

jedrzej.kurylo Over a year ago

How do you know it's run synchronously? You have the queue:listen running so it might still be handled asynchronously but you're getting logs in correct order because it might be handled why your code is doing sleep(). Stop queue:listen process, dispatch the job without it running and see if the job gets executed.

user2099451 Over a year ago

thank you for help , I mean for me it seems to be sync, but I want it to be async ,, how to achieve that ?

jedrzej.kurylo Over a year ago

When you stop "queue:listen" - does the job get handled?

user2099451 Over a year ago

yes , it works , but when the queue:listen works or not , its sync. while I want it to work async , I'm using the localhost , is that affect the use of queuing ?

Anshu Shekhar · Accepted Answer · 2016-02-01 19:35:58Z

0

Use this command to create the job:

   php artisan make:job SendGiftCommand --queued

Refer this link for defining the job:

 https://laravel.com/docs/5.1/queues#writing-job-classes

Then pass declare the job and dispatch the job in this manner:

    $processGift = new sendGiftCommand($model1);
    $this->dispatch($processGift);

Also refer Supervisor Configuration on the above mentioned link further for continuously listening to the queue or automatically restarting the command queue:listen if they fail.

answered Feb 1, 2016 at 19:35

Anshu Shekhar

3413 silver badges8 bronze badges

Collectives™ on Stack Overflow

Async Queues In Laravel

3 Answers 3

3 Comments

5 Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

3 Comments

5 Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related