davelip / laravel-database-queue by davelip

86,077
22
3
Package Data
Maintainer Username: davelip
Maintainer Contact: lippi.david@gmail.com (David Lippi)
Package Create Date: 2014-11-19
Package Last Update: 2018-08-27
Language: PHP
License: MIT
Last Refreshed: 2024-11-27 15:02:58
Package Statistics
Total Downloads: 86,077
Monthly Downloads: 939
Daily Downloads: 27
Total Stars: 22
Total Watchers: 3
Total Forks: 12
Total Open Issues: 0

Laravel 4 Database Queue Driver

Push a function/closure to the Database queue.

This is a real queue driver, like beanstalkd or redis one. You need a daemon like supervisor or similar to listen to your queue.

Install

Add the package to the require section of your composer.json and run composer update

"davelip/laravel-database-queue": ">0.5"

Add the Service Provider to the providers array in config/app.php

'Davelip\Queue\DatabaseServiceProvider'

I suggest to publish migrations, so they are copied to your regular migrations

$ php artisan migrate:publish davelip/laravel-database-queue

And then run migrate

$ php artisan migrate 

I suggest to create the failed_jobs table, in this moment, with:

$ php artisan queue:failed-table

You should now be able to use the database driver in config/queue.php

'default' => 'database',

'connections' => array(
    ...
    'database' => array(
        'driver' => 'database',
        'queue' => 'queue-name', // optional, can be null or any string
        'lock_type' => 0, // optional, can be 0, 1 or 2
    ),
    ...
}

It work in the same as beanstalkd or redis queue listener.

Listen for new job:

$ php artisan queue:listen

Concurrency are managed by status column in the queues table, so you can parallelize your queue:listen.

Atomicity of status change are garantee by database transaction, if you are having problems of race condition can You set the option lock_type to:

  • 'lock_type' => 1 // queue system will use sharedLock
  • 'lock_type' => 2 // queue system will use lockForUpdate

see http://laravel.com/docs/4.2/queries#pessimistic-locking for further info.

Laravel Queue System

For more info see http://laravel.com/docs/queues

Thanks

Loosely based on https://github.com/barryvdh/laravel-async-queue