v2.1.0
What's Changed
- Added
auto_ack
option to the Job class by @butschster in #14
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