PHP code example of shipsaas / laravel-priority-queue
1. Go to this page and download the library: Download shipsaas/laravel-priority-queue library. Choose the download type require.
2. Extract the ZIP file and open the index.php.
3. Add this code to the index.php.
<?php
require_once('vendor/autoload.php');
/* Start to develop here. Best regards https://php-download.com/ */
shipsaas / laravel-priority-queue example snippets
'connections' => [
// ... a lot of connections above
// then our lovely guy here
'database-priority' => [
'driver' => 'database-priority',
'connection' => 'mysql',
'table' => 'priority_jobs',
'queue' => 'default',
'retry_after' => 90,
'after_commit' => false, // or true, depends on your need
],
],
class SendEmail implements ShouldQueue
{
public int $jobWeight = 500;
}
use ShipSaasPriorityQueue\Traits\UseJobPrioritization;
class SendEmail implements ShouldQueue
{
use UseJobPrioritization;
public function getJobWeight() : int
{
return $this->user->isUsingProPlan()
? 1000
: 500;
}
}
// use Dispatcher
SendEmail::dispatch($user, $emailContent)
->onConnection('database-priority');
// use Queue Facade
use Illuminate\Support\Facades\Queue;
Queue::connection('database-priority')
->push(new SendEmail($user, $emailContent));
class SendEmail implements ShouldQueue
{
// first option
public $connection = 'database-priority';
public function __construct()
{
// second option
$this->onConnection('database-priority');
}
}