I’m working on a platform where microservices publish events to a central message bus.
Some of these events should trigger a new aggregate instance in one or more services.
Should I use a Saga to convert the events to commands?
msg --> IncomingEventHandler --> Saga --> Aggregate
This looks like a lot of plumbing.
Another option would be to deserialize the messages as commands and send them through the gateway.