Queue registration and dispatcher lifecycle.
A DynamicSupervisor that starts one Kathikon.Dispatcher per queue.
start_configured/0 runs at application boot; ensure_started/1 is
called on each Kathikon.insert/3.
Example
:ok = Kathikon.Queue.ensure_started(:emails)See docs/guides/queues-and-concurrency.md.
Summary
Functions
Returns a specification to start this module under a supervisor.
Ensures a dispatcher is running for the given queue.
Starts dispatchers for all configured queues.
Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
@spec ensure_started(atom()) :: :ok
Ensures a dispatcher is running for the given queue.
@spec start_configured() :: :ok
Starts dispatchers for all configured queues.