Download the PHP package waaseyaa/queue without Composer

waaseyaa/queue

Layer 0 — Foundation

Async job queue for Waaseyaa applications.

SyncQueue is intentionally inline: handler exceptions propagate to the dispatching caller and are not copied to the failed-job repository. Persistent drivers execute through Worker, which records exhausted jobs and logs a throwing Job::failed() hook without allowing that secondary failure to stop the worker.

Persistent dispatch accepts any object, but successful consumption requires a supporting worker handler. If no handler supports an accepted message, Worker raises a typed UnhandledQueueMessage failure and applies its configured bounded retry/backoff policy. On exhaustion, the signed payload and failure are stored in the failed-job repository before the delivery is rejected; it is never silently acknowledged. The error identifies the message class without exposing its payload.

Application jobs subclass Job and implement handle(). There is no JobInterface. Dispatch through QueueInterface. Job middleware lives on foundation JobMiddlewareInterface, not in this package.

Key classes: Job, QueueInterface.

Persistent scheduler delivery is an explicit extension rather than an implied QueueInterface::dispatch() guarantee. OccurrenceQueueInterface attaches the immutable QueueOccurrenceV1 identity to the signed authority envelope, and Worker delegates lease acquisition, fencing, completion, and dead-letter transitions to the scheduler-supplied OccurrenceRuntimeInterface. The queue transport reservation remains delivery mechanics, never execution ownership.

Persistent payload integrity

DbalQueue signs every serialized message with HMAC-SHA-256 under the waaseyaa.queue.payload-hmac.v1 application-derived key. Worker verifies the strict versioned envelope before deserialization. Failed-job rows retain the same signed envelope, and queue:retry verifies it before re-dispatch.

Existing pending and failed rows do not have this envelope. Before deploying this change, either drain them with the previous release or intentionally clear waaseyaa_queue_jobs and waaseyaa_failed_jobs. Persistent readers do not keep an unsigned compatibility mode.

Hot-path note: HKDF runs once when the queue services are constructed. Each dispatch performs one HMAC-SHA-256 plus URL-safe base64 encoding; each worker or retry read performs one base64 decode, one HMAC-SHA-256, and one constant-time comparison before the existing serialization work.

When an ApplicationMasterKeyring is composed, new persistent payloads use the active master version in the strict hmac-sha256.application-master.v1:<version>:<digest>:<payload> envelope. Declared predecessor versions remain readable through the keyring. The legacy application-secret envelope is refused by default in keyring mode; the bounded cutover-only queue.accept_legacy_application_secret_payloads flag may enable its verifier while old rows are drained.

The database queue contributes waaseyaa.queue.payload-hmac.v1 with the drain-or-expire strategy. Forward inventory refuses until both pending and failed legacy/predecessor rows are empty, and rollback refuses until failed successor rows are empty. The adapter never deletes or rewrites jobs: operators and workers must drain them before the zero-row snapshot, and verification rechecks the database so a stale writer blocks completion.

Local PHP 8.5.8 microbenchmark (2026-07-15, 100,000 in-memory seal+open round trips over a serialized empty object): 396.58 ms total, 3.966 µs per round trip. This isolates envelope work from database and job execution time.