PHPackages roman-1983/messenger-worker-registry - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. [Logging & Monitoring](/categories/logging) 4. / 5. roman-1983/messenger-worker-registry ActiveSymfony-bundle[Logging & Monitoring](/categories/logging) roman-1983/messenger-worker-registry ==================================== Worker registry for Symfony Messenger — track running workers, transports, and message stats via console v1.1.1(2mo ago)069MITPHPPHP >=8.2CI passing Since Mar 3Pushed 2mo agoCompare [ Source](https://github.com/roman-1983/shopwatch-messenger-worker-registry)[ Packagist](https://packagist.org/packages/roman-1983/messenger-worker-registry)[ Docs](https://github.com/roman-1983/shopwatch-messenger-worker-registry)[ RSS](/packages/roman-1983-messenger-worker-registry/feed)WikiDiscussions main Synced 1mo ago READMEChangelogDependencies (8)Versions (4)Used By (0) Messenger Worker Registry ========================= [](#messenger-worker-registry) The Messenger Worker Registry component provides real-time visibility into your Symfony Messenger workers. Track running workers, their transports, message throughput, failure rates, and per-message-type performance — all via a simple console command. Features -------- [](#features) - **Zero configuration** — install the bundle and it just works - **Automatic registration** — workers register themselves on startup via event listeners - **Worker status** — see at a glance which workers are `running`, `stopped`, or `dead` - **Hostname tracking** — identify which host each worker is running on - **Heartbeat with TTL** — crashed workers show as "dead" before expiring from the registry - **Configurable TTL** — adjust the TTL to match your environment - **Message counters** — track handled and failed messages per worker - **Per-message-type stats** — see count, failure rate, and average processing time per message class - **Console command** — `messenger:worker:list` with table and JSON output - **No external dependencies** — uses Symfony's built-in PSR-6 cache (filesystem, Redis, APCu — whatever you have configured) Requirements ------------ [](#requirements) - PHP 8.2+ - Symfony 7.0+ or 8.0+ Installation ------------ [](#installation) ``` composer require roman-1983/messenger-worker-registry ``` If you're not using Symfony Flex, register the bundle manually: ``` // config/bundles.php return [ // ... ShopWatch\MessengerWorkerRegistry\MessengerWorkerRegistryBundle::class => ['all' => true], ]; ``` That's it. No configuration needed — the defaults work out of the box. Usage ----- [](#usage) ### List Running Workers [](#list-running-workers) ``` bin/console messenger:worker:list ``` [![messenger:worker:list](docs/worker-list.png)](docs/worker-list.png) ### Worker Status [](#worker-status) Each worker has one of three statuses: StatusMeaning`running`Worker is active, heartbeat received within TTL`stopped`Worker shut down gracefully via `WorkerStoppedEvent``dead`Worker crashed — no heartbeat received for longer than TTLStopped workers remain visible for 1x TTL after shutdown. Dead workers remain visible for 2x TTL after their last heartbeat, then expire from the cache automatically. ### Detailed View with Per-Message Stats [](#detailed-view-with-per-message-stats) ``` bin/console messenger:worker:list --detail ``` [![messenger:worker:list --detail](docs/worker-detail.png)](docs/worker-detail.png) ### JSON Output [](#json-output) ``` bin/console messenger:worker:list --format=json bin/console messenger:worker:list --format=json --detail ``` Returns a JSON array for programmatic consumption: ``` [ { "id": "a3f21b8e", "status": "running", "hostname": "web-01", "transports": ["scheduler_uptime", "high", "medium"], "started_at": "2026-03-03T14:22:10+00:00", "last_active_at": "2026-03-03T14:24:55+00:00", "messages_handled": 142, "messages_failed": 0, "message_stats": { "CheckUptimeMessage": { "count": 120, "failed": 0, "avg_ms": 198.3, "total_ms": 23796.0 } } } ] ``` The `message_stats` key is only included when using `--detail`. How It Works ------------ [](#how-it-works) The bundle listens to Symfony Messenger's built-in worker events: EventAction`WorkerStartedEvent`Registers the worker with a generated ID, hostname, and transport list`WorkerRunningEvent`Sends a heartbeat every 30s to extend the cache TTL`WorkerStoppedEvent`Marks the worker as "stopped" (stays visible for 1x TTL)`WorkerMessageReceivedEvent`Starts a timer for processing duration`WorkerMessageHandledEvent`Increments handled counter, records per-type stats`WorkerMessageFailedEvent`Increments failed counter, records per-type stats### TTL and Worker Lifecycle [](#ttl-and-worker-lifecycle) Each worker entry is stored with a cache TTL of **2x the configured TTL**(default: 240 seconds). The heartbeat (fired every 30 seconds) resets this TTL on each cycle. - **Running**: Heartbeat keeps the entry alive. Status is "running" as long as `lastActiveAt` is within 1x TTL. - **Crashed**: If a worker crashes without triggering `WorkerStoppedEvent`, its `lastActiveAt` goes stale. After 1x TTL it shows as "dead". After 2x TTL the cache entry expires automatically. - **Graceful stop**: `WorkerStoppedEvent` sets `stoppedAt` and saves the entry with 1x TTL. It shows as "stopped" until it expires. ### Storage [](#storage) The bundle uses Symfony's `cache.app` pool by default. This means it works out of the box with whatever cache adapter you have configured (filesystem, Redis, Memcached, APCu). For multi-server setups, make sure your cache adapter is shared (e.g., Redis). > **Docker / multi-container note:** If your web server and workers run in separate containers with the default filesystem cache adapter, they each have an isolated filesystem. Workers will register themselves, but the web container won't see them. To fix this, either mount a **shared volume** on the cache directory (e.g., `/app/var/share`) across all containers, or switch to a shared cache adapter like Redis. Configuration ------------- [](#configuration) The bundle works without any configuration. You can optionally customize the TTL: ``` # config/packages/messenger_worker_registry.yaml messenger_worker_registry: ttl: 120 # seconds (default: 120, minimum: 10) ``` To use a dedicated cache pool instead of `cache.app`, override the service definition: ``` # config/services.yaml services: ShopWatch\MessengerWorkerRegistry\WorkerRegistry: arguments: $cache: '@cache.pool.worker_registry' ``` Testing ------- [](#testing) ``` composer install vendor/bin/phpunit ``` Resources --------- [](#resources) - [Contributing](CONTRIBUTING.md) - [Report issues](https://github.com/roman-1983/messenger-worker-registry/issues) and [send Pull Requests](https://github.com/roman-1983/messenger-worker-registry/pulls) please. License ------- [](#license) MIT License. See [LICENSE](LICENSE) for details. ### Health Score 41 — FairBetter than 89% of packages Maintenance86 Actively maintained with recent releases Popularity13 Limited adoption so far Community6 Small or concentrated contributor base Maturity48 Maturing project, gaining track record Bus Factor1 Top contributor holds 100% of commits — single point of failure How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~0 days Total 3 Last Release 69d ago ### Community Maintainers ![](https://www.gravatar.com/avatar/7a38120affa7e137b517d7829a77330ffe2c091c78a53eaf258c5ebc0c1f7f6a?d=identicon)[roman-1983](/maintainers/roman-1983) --- Top Contributors [![roman-1983](https://avatars.githubusercontent.com/u/3573021?v=4)](https://github.com/roman-1983 "roman-1983 (7 commits)") --- Tags composer-packagesymfonysymfonymonitoringworkerMessengerregistry ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/roman-1983-messenger-worker-registry/health.svg) ``` [![Health](https://phpackages.com/badges/roman-1983-messenger-worker-registry/health.svg)](https://phpackages.com/packages/roman-1983-messenger-worker-registry) ``` ### Alternatives [sulu/sulu Core framework that implements the functionality of the Sulu content management system 1.3k1.3M152](/packages/sulu-sulu)[shopware/platform The Shopware e-commerce core 3.3k1.5M3](/packages/shopware-platform)[prestashop/prestashop PrestaShop is an Open Source e-commerce platform, committed to providing the best shopping cart experience for both merchants and customers. 9.0k15.4k](/packages/prestashop-prestashop)[shopware/storefront Storefront for Shopware 684.2M148](/packages/shopware-storefront)[shopware/core Shopware platform is the core for all Shopware ecommerce products. 595.2M386](/packages/shopware-core)[patchlevel/event-sourcing-bundle symfony bundle for patchlevel/event-sourcing 50146.1k1](/packages/patchlevel-event-sourcing-bundle) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)