hypervel / queue

v0.3.26 2026-07-02 06:43 UTC

Requires

• php: ^8.2
• hyperf/collection: ~3.1.0
• hyperf/contract: ~3.1.0
• hyperf/coordinator: ~3.1.0
• hyperf/coroutine: ~3.1.0
• hyperf/db-connection: ~3.1.0
• hyperf/support: ~3.1.0
• hyperf/tappable: ~3.1.0
• hypervel/core: ^0.3
• hypervel/encryption: ^0.3
• hypervel/support: ^0.3
• laravel/serializable-closure: ^1.2.2
• ramsey/uuid: ^4.7
• symfony/process: ^7.0

Suggests

• ext-filter: Required to use the SQS queue worker.
• ext-mbstring: Required to use the database failed job providers.
• ext-pcntl: Required to use all features of the queue worker.
• ext-pdo: Required to use the database queue worker.
• ext-posix: Required to use all features of the queue worker.
• aws/aws-sdk-php: Required to use the SQS queue driver and DynamoDb failed job storage (^3.235.5).
• pda/pheanstalk: Required to use the Beanstalk queue driver (^5.0.6|^7.0.0).

MIT

• Albert Chen

• queue
• php
• swoole
• hyperf
• hypervel

Published on Packagist.org on 2026-08-14 06:29 UTC

README

Documentation: https://hypervel.org/docs/queues

Differences From Laravel

• Daemon jobs own their database routing, log context and scoped-container state. Laravel's Worker::$flushStickyConnections setting and the worker constructor's $resetScope callback are omitted; a worker-wide reset could affect concurrent jobs. See porting queues.
• Laravel's DynamoDB failed-job provider is not provided. Use database or file storage for failed jobs.
• Custom job implementations must support JobLifecycleCallbacks to use CountCrashesAsExceptions, so cleanup completes before a concurrent retry starts. The base Jobs\Job already implements it; the Job contract is unchanged. See counting worker crashes.
• Timeouts unwind yielding job code with Swoole's CanceledException, starting its catch and finally blocks. Use finally for cleanup and rethrow cancellation if caught. The worker stops after timeout handling by default, with a bounded wait for cleanup; Worker::$killOnTimeout = false keeps other jobs running. See worker timeouts for cleanup and blocked-loop recovery.
• The protected enqueueUsing() callback receives the queue that owns the operation as its first argument. This lets deferred work borrow a fresh pooled queue connection after a database transaction commits instead of retaining a connection for the lifetime of the transaction.
• Positive per-message delays on SQS FIFO queues throw LogicException. Laravel silently omits the delay and sends the job immediately.
• RateLimited::releaseAfter(0) requests an immediate retry. Laravel treats zero as absent and uses the limiter's computed retry delay.
• RedisQueue::scanQueueKeys() is intentionally omitted. Queue discovery streams keys on a held connection instead of materializing a physical-key array; override allQueueNames() to customize discovery.
• Redis bulk dispatch uses enqueueBatch() and LuaScripts::bulk() for both standalone Redis and Cluster, storing immediate and delayed jobs together with an exact completion count. Laravel's RedisQueue::bulkOnClusterConnection() and LuaScripts::bulkPush() helpers are intentionally omitted.

Ported from: https://github.com/laravel/framework/tree/13.x/src/Illuminate/Queue