Performing wait/sleep activities in Akka actors -
is there issue if have sleep/wait activity inside actor, taking blocking queue?
my use case: implementing basic etl fed data heterogeneous sources (file, sms, email). have source specific receivers, can trigger extract-transform-load sequence flow on events. orchestrating flow using akka actors (mainly achieve parallelism , fault handling/retrial).
for file , email, "pull" receivers, new flow triggered on event receipt. sms, "push" receiver, plan have single flow, extractor listening on durable queue, , receiver queue on event receipt.
we using fork-join dispatcher , single e-t-l actors.
Comments
Post a Comment