elavora / api-queue-worker

v0.2.0 2026-07-10 17:29 UTC

Requires

• php: >=8.1
• elavora/api-framework: ^0.3.1

Requires (Dev)

• phpunit/phpunit: ^10.5 || ^11.0 || ^12.0

MIT

Published on Packagist.org on 2026-07-10 17:29 UTC

README

Worker opcional para consumir tarefas publicadas em qualquer implementacao do contrato Elavora\Api\Framework\Contracts\Queue.

$payload = new TaskPayload('emails.send', ['email' => '[e-mail]']);
$queue->push('default', $payload->toArray());

$registry = (new TaskRegistry())->add('emails.send', new SendEmailTaskHandler());
$worker = new QueueWorker($queue, $registry);
$worker->workOnce('default');

Use TaskPayload::fromArray() para reconstruir payloads serializados pela fila. O worker reencaminha tarefas com falha enquanto maxAttempts nao for atingido.