[akka-user] Re: Starting an FSM in a cluster

2014-05-03 Thread Eugene Dzhurinsky
I have one more question, if you please. It seems that you have a control actor (singleton), which knows about Pipelines, and the pipelines are actually started in a cluster. And every pipeline creates its own set of FSM actors *locally**, *passing them the references to the stateless worker ac

Re: [akka-user] Re: Starting an FSM in a cluster

2014-05-03 Thread Eugene Dzhurinsky
On Sat, May 03, 2014 at 04:16:34PM -0700, Ryan Tanner wrote: > That's pretty much what we do. We give one of our nodes the "supervisor" > role and start a ClusterSingletonActor on it which spawns a control FSM (we > call it a Pipeline) which in turn spawns worker FSMs (PipelineWorkers). > Thos

[akka-user] Re: Starting an FSM in a cluster

2014-05-03 Thread Ryan Tanner
That's pretty much what we do. We give one of our nodes the "supervisor" role and start a ClusterSingletonActor on it which spawns a control FSM (we call it a Pipeline) which in turn spawns worker FSMs (PipelineWorkers). Those actors then marshall data and delegate work to stateless actors el

[akka-user] Starting an FSM in a cluster

2014-05-03 Thread Eugene Dzhurinsky
Hello! I'm trying to implement rather complex task processing, which involves starting a "Control FSM" actor per task, it starts a set of "Worker FSM" actors, and every "Worker FSM" sends m

Re: [akka-user] mixing FSM and akka-persistence

2014-05-03 Thread Konrad Malawski
> > Is it possible to use Processor and FSM together? > Yes, http://doc.akka.io/docs/akka/snapshot/scala/persistence.html#state-machines What problems are you seeing? -- Cheers, Konrad 'ktoso' Malawski hAkker - Typesafe, Inc -- >> Read the docs: http:/

[akka-user] mixing FSM and akka-persistence

2014-05-03 Thread Nicola Piccinini
hi all, I am trying to do something like: class MyFSM extends Processor with FSM and at first it seems that it does not work properly. Is it possible to use Processor and FSM together? Thanks, Nicola -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: