v2.9.0

What's Changed

• Adds consume_all option to the AMQPCreateInfo DTO by @butschster in #44
• Starting from v2023.1.0, RR requires a queue name (if the consumer is used) or/and routing key for the push operations. by @butschster in #45

Full Changelog: v2.8.1...v2.9.0

v2.8.1

What's Changed

• Update AMQPCreateInfo by @rauanmayemir in #42

Full Changelog: v2.8.0...v2.9.0

v2.8.0

What's Changed

• Added options to the create method by @msmakouz in #39

Full Changelog: v2.7.0...v2.8.0

v2.7.0

What's Changed

• Adding ReceivedTaskFactory, adding KafkaReceivedTask by @msmakouz in #36

Full Changelog: v2.6.0...v2.7.0

v2.6.0

What's Changed

• Adding headers to Options by @msmakouz in #27
• Fixing tags and attributes in SQS by @msmakouz in #28

Full Changelog: v2.5.1...v2.6.0

v2.5.1

What's Changed

• Fixes problem with receiving empty payload body. by @butschster in #25

Full Changelog: v2.5.0...v2.5.1

v2.5.0

What's Changed

• Mark Jobs::isAvailable method as deprecated. by @butschster in #23

Full Changelog: v2.4.0...v2.5.0

v3.0.0

What's Changed

• Removed opis/closure serializer by @msmakouz in #19

Full Changelog: v2.3.0...v3.0.0

v2.4.0

What's Changed

• Adds support for kafka and boltdb pipelines by @butschster and @msmakouz in #22

Create kafka pipeline

use Spiral\RoadRunner\Jobs\Queue\KafkaCreateInfo;
use Spiral\RoadRunner\Jobs\Jobs;

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

$kafkaCreateInfo = new KafkaCreateInfo(
     name: 'kafka-queue',
     topic: 'subscription',
     maxOpenRequests: 1000
);

$queue = $jobs->create($kafkaCreateInfo);

Push job into kafka pipeline

use Spiral\RoadRunner\Jobs\KafkaOptions;
use Spiral\RoadRunner\Jobs\Queue\Kafka\PartitionOffset;

$queue->dispatch(
      $queue->create(
            'job:name',
            ['foo' => 'bar'],
            new KafkaOptions(
                  topic: 'some-topic',
                  metadata: 'foo-bar',
                  offset: PartitionOffset::OFFSET_NEWEST
            )
      )
);

Changing options in a prepared task:

$queue = $jobs->create($kafkaCreateInfo);
        
$task = $queue->create(
    'job:name',
    ['foo' => 'bar'],
    new KafkaOptions(
        topic: 'some-topic',
        metadata: 'foo-bar',
        offset: PartitionOffset::OFFSET_NEWEST
    )
);
        
$queue->dispatch($task->withOptions(new KafkaOptions(
    topic: 'other',
    metadata: 'foo-bar',
    offset: PartitionOffset::OFFSET_NEWEST
)));

$queue->dispatch($task->withOptions($task->getOptions()->withTopic('other')));
$queue->dispatch($task->withDelay(10));

---

Create boltdb pipeline

use Spiral\RoadRunner\Jobs\Queue\BoltdbCreateInfo;
use Spiral\RoadRunner\Jobs\Jobs;

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

$boltdbCreateInfo = new BoltdbCreateInfo(
     name: 'boltdb-queue',
     file: 'rr.db'
);

$queue = $jobs->create($boltdbCreateInfo);

Full Changelog: v2.3.2...v2.4.0

v2.3.2

What's Changed

• Fixes default task priority in a queue. by @butschster in #21

Full Changelog: v2.3.1...v2.3.2