Re: [akka-user] Distributed workers question

Eric, In your approach, the master is pushing work towards the workers whereas in the other approach the workers are pulling work (technically its still a push, but only after readiness has been signaled). The pull based approach might be advantageous if the work is not evenly distributed, e.g. be

[akka-user] Distributed workers question

Hi all. I have a question based on the Activator template "akka distributed workers". I have already written a system very similar to this one. The main difference is that I don't have the workers register with the master. The master simply uses a cluster-based router to round-robin out work to

[akka-user] [akka-stream] how to handle Future

Hi, How should Future be handled in akka-stream? For example, if one step of a Flow is an http request, when and where should the ActorSystem be shutdown? benq -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/curren

[akka-user] How to Store the Message Object/Class to a database?

Hi, I encountered this problem while trying to write a program that has some sort of ability to "undo" its own action. I thought this data structure could do the trick: originalValue[String], changedValue[String], actorAddress[String], message[??]. Since Akka actor can send messages accord

[akka-user] UntypedEventSourcedProcessor and Channels

Hi, I'm kind of new to Akka, and am using its Java API only. I have a question regarding using Event Sourcing with reliable communications between Actors: I understand that 1) UntypedEventsourcedProcessor cannot receive Persistent messages 2) In order to send a message reliably to another actor

Re: [akka-user] How can the sender know that a message has been delivered (confirmed) by a channel?

Hi Roland, All good and thanks for being helpful. That clears things up :) Btw, PersistentActor has a good ring to it. On Tuesday, May 27, 2014 8:44:11 AM UTC+1, rkuhn wrote: > > Hi Alex, > > 26 maj 2014 kl. 21:57 skrev ahjohannessen > >: > > Hi Roland, > > the main concern you express is tha

Re: [akka-user] JMX & Akka

Hello Andreas, Yes, the Typesafe Console is being EndOfLife-ed. JMX support is still around in some Akka modules. It depends which values explicitly you're after, but for Cluster we have the ClusterJmx bean (here it's spec

Re: [akka-user] Cluster Singleton duplicated if primary seed restarted

Hello Jeroen, Indeed the options that you have listed are the other available, thus recommended, options. Truth be told, keeping a large cluster running does require some more tooling, ops skills or people to take care of it. In practice you could hook into monitoring services like Nagios or Zabbix

Re: [akka-user] Re: Multi-jvm test property settings when using "sbt test"

I got the same problem . Every time I execute gen-idea ,I mark the "multi-jvm/scala" as Test Source Root manual in the Idea-13.1 IDE. After do that action, I can edit code in idea ide. But the multi-jvm test can only execute in sbt command line,do you know how to run the test in idea ide? 在 201

Re: [akka-user] Does akka-persistence demand incorruptible actor state?

On Tue, May 27, 2014 at 12:24 AM, Jeroen Gordijn wrote: > Hi Patrik, > > This makes sense. I am using event sourcing in some places to ensure that > some action is performed (channels will be removed/changed right). In > preStart I send a message to self to restart processing. The actor rebuilds >

Re: [akka-user] Re: Inconsistent behavior of ClusterClient.Send (akka 2.3.2) ?

On Tue, May 27, 2014 at 7:41 AM, Patrik Nordwall wrote: > > > > 27 maj 2014 kl. 04:43 skrev Eugene Dzhurinsky : > > It *seems* that I've fixed this weird behavior by making messages, being > sent to the cluster, implementing the *ConsistentHashable* trait > > At least, the sample project and the c