This library distributes new events to specific channels as per their EventAction type, in a fan-out approach.
How it works:
- Listen for new events on specified topic.
- Filter events and only process ones for the specified Aggregate.
- Get the Max Aggregate-Version from Database.
- Send request to EventStoreQuery with the Max Aggregate-Version.
- Get events from EventStoreQuery.
- Fan-Out events to their respective channels based on
Event.EventAction.
- Check examples for how to use this library.
- Check tests-file for additional examples.