Forja.Processor
(Forja v0.4.0)
View Source
Functional core of event processing.
Orchestrates the flow:
- Loads the event from the database
- Checks if it has already been processed (
processed_at) - Dispatches to handlers via Registry
- Marks as processed
- Broadcasts via PubSub
Called by the Oban worker and the reconciliation worker. This module has no state -- it is a pure functional module.