Skip to content

v2.1.0

Compare
Choose a tag to compare
@butschster butschster released this 16 May 18:16
9a49b10

What's Changed

use Spiral\RoadRunner\Jobs\Queue\MemoryCreateInfo;
use Spiral\RoadRunner\Jobs\Options;
use Spiral\RoadRunner\Jobs\Jobs;

// Create with default values
$options = new Options();

// Jobs service
$jobs = new Jobs(RPC::create('tcp://127.0.0.1:6001'));

// Select "test" queue from jobs
$queue = $jobs->connect('test');

// or create a new queue
$queue = $jobs->create(new MemoryCreateInfo('local'));

// Set default auto ack for all tasks
$queue = $queue->withDefaultOptions(
     $options->withAutoAck(true)
);

// Create a new task with custom auto ack
$task = $queue->push(
     'task_name', 
     ['foo' => 'bar'], 
     (new Options())->withAutoAck(false)
);

// or change auto ack for created task
$task = $queue->create(
     'task_name', 
     ['foo' => 'bar']
)->withAutoAck(false);

$queue->dispatch($task);

Full Changelog: v2.0.5...v2.1.0