Queue
Table of Contents
Namespaces
- Stamp
- Transport
Classes
- HandlerRegistry
- Runtime view of the compiled `#[Maho\Config\MessageHandler]` registry.
- Pool
- A worker pool: one or more `queue:work` processes consuming a subset of the
logical queues, with their own limits. Pools keep
latency classes apart, so a ten-minute feed build cannot sit in front of an
order confirmation email.
- PoolRegistry
- Reads the worker pools declared under `<global><queue><pools>`, so a module
can attach its queue to a tier without touching core.
- QueueManager
- Entry point of the Maho message queue: dispatch a message object and a
compiled `#[Maho\Config\MessageHandler]` method consumes it asynchronously.
- ServiceLocator
- Minimal PSR-11 container over a fixed service map, for Messenger's
senders-by-transport-name and retry-strategies-by-transport-name locators.
- ServiceNotFoundException
- StopWorkerOnConfigChangeListener
- Stops the worker when store configuration changes, so it restarts with
fresh settings instead of running on the config it booted with (a stale
worker would e.g. keep sending email through an old SMTP transport). The
watchdog respawns a stopped worker within a minute.
- StopWorkerWhenIdleListener
- Stops the worker once polls stop finding messages, for bounded runs and for
on-demand pools that free their process between bursts. Messenger has no
built-in stop-on-idle listener.
- TraceMessageListener
- A worker outlives thousands of messages, so one span per process would hold
every child in memory and export nothing until the process died.
- WorkerFactory
- Builds a Messenger Worker wired with Maho's retry policy and failure
semantics. Time limits are passed to Worker::run() as options by the caller;
message and memory limits are listener-based.