I want to build a play application fetching different API's, persisting the processed results and stream the results via WebSockets to web clients.
I have N actors for N API's in the main controller who are injected by AkkaGuice. Then I have N GraphStages that are in fact responsible for the whole process of getting Data from the DataSources do all the preprocessing, persisting the data and publishing the data to the ActorSystem event stream. The API actors subscribe the ActorSystem event stream look for Messages of their interest and forward them to the Dynamically Created User Actors (here I used the pattern from the https://github.com/playframework/play-scala-websocket-example) I really enjoy the idiomatic approach writing data processing logic with the graph DSL but publishing the data on the EventStream feels wrong. I thought something about to have a single graph stage that I inject inside the controller by starting the app which handles the whole fetching and persistence logic but also is able to distribute the data to the dynamical group of user actors but without publishing it to the EventStream Is there an idiomatic approach to solving my problem? Thanks Ivan -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
