Basically, I want to implement a workflow like
B0---C0
/ \
A ---B1-----C1--D----E----F
\ /
B2---C2
using only message queues. I'm thinking that every message will be sent to a forwarder/dispatcher that has logic like
switch message_result
case A
split to B0,..,BN and forward to service that processes Bis to Cis
case Ci
if is final Ci
aggregate Cis into D and forward to service that processes D
else
add to collection of accumlated Cis
case E
do something with result and forward to F
Is there a name for this type of pattern?
Aucun commentaire:
Enregistrer un commentaire