Re: [akka-user] Quarantined?

Examples of such system messages are watch messages and remote deployment. If you don't use these features it will not be quarantined. /Patrik On Thu, Dec 24, 2015 at 1:29 PM, jie tang wrote: > Hi, all: > I have read >

Re: [akka-user] Quarantined?

Thanks. On Fri, Dec 25, 2015 at 4:41 PM, Patrik Nordwall wrote: > Examples of such system messages are watch messages and remote deployment. > If you don't use these features it will not be quarantined. > /Patrik > > On Thu, Dec 24, 2015 at 1:29 PM, jie tang

Re: [akka-user] Re: Deserialize ActorRef, again

That should be the same thing, if there is only one binding to "java". tors 24 dec. 2015 kl. 17:19 skrev : > Is there a difference between doing > > serializers { >java = "com.romix.akka.serialization.kryo.KryoSerializer" > } > > and > > serializers { >myown =

[akka-user] Re: Akka PersistenceQuery java example

Thanks Patrik, you where correct. Now that I have confirmed that my events are persisted. How do I use it in an object that extends a PersistenceQuery? And how do I read different types of events (different persistence id) in same persistence query? For example, NewCustomerEstablishedEvent,

Re: [akka-user] Re: Akka PersistenceQuery java example

Perhaps you terminate the system too early. Note that source.runForeach is asynchronous, i.e. returns immediately. On Thu, Dec 24, 2015 at 1:50 PM, Jan-Terje Sørensen wrote: > I have tryed with setting same id's, but still not able to list events. > > Are you able to show

[akka-user] Re: Akka PersistenceQuery java example

Thanks Patrik, you where correct. Now that I have confirmed that my events are persisted. How do I use it in an object that extends a PersistenceQuery? And how do I read different types of events (different persistence id) in same persistence query? For example, NewCustomerEvent,

Re: [akka-user] Aggregate counts in multi-jvm testing

Or CRDT with any distributed data structure, I can mention a couple: Hazelcast, Riak, etc Basically you want a distributed counter. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html

Re: [akka-user] Aggregate counts in multi-jvm testing

After having consulted a number of customers who included or previously-had hazlecast clusters along with  Akka apps I remain unconvienced what hazlecast added to the table (other than - "yet another cluster, with different and detached lifecycle to manage"). I'd avoid adding more separate

Re: [akka-user] Re: Deserialize ActorRef, again

See reference.conf files in akka. Also included in config section of docs. akka-cluster is mapped to a serializer that is using protobuf. ActorRef is java serialization, but it has custom readResolve and writeReplace fre 25 dec. 2015 kl. 16:33 skrev : > In the example

[akka-user] Shut down an actor system in multi-jvm tests

Hi hAkkers, I've been trying to figure out how to gracefully shutdown an actor system (or a jvm) in multi-jvm tests. The most naive way, which is to run system.terminate gives some error about Barrier timeout. I also tried TestConductor(system).shutdown(first), but I got an error about

[akka-user] Re: Akka PersistenceQuery java example

Aha! I did not know that different events could have same persistenceId. Is the persistenceId the same as an aggregate then? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>

Re: [akka-user] Aggregate counts in multi-jvm testing

Without going much deeper – I certainly wouldn't add any of these to a project just to get a CRDT counter ;-) Also, we have those too:  http://doc.akka.io/docs/akka/snapshot/scala/distributed-data.html :-) --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 25 December 2015 at 11:22:07,

Re: [akka-user] Re: Akka PersistenceQuery java example

Different types of events, same persistenceId, => you can use stream operators, such as filter, map, collect. Different persistenceId => then you should use the eventsByTag query /Patrik On Fri, Dec 25, 2015 at 10:08 AM, Jan-Terje Sørensen wrote: > Thanks Patrik, you

Re: [akka-user] Aggregate counts in multi-jvm testing

I see. Thanks a lot! On Fri, Dec 25, 2015 at 9:43 AM, wrote: > Exactly, I wouldn't want to add another piece to get those counters for > the test. So I'm definitely gonna use akka's distributed data for this. > > @Konrad 'ktoso’ Malawski: I'm curious about your

Re: [akka-user] Aggregate counts in multi-jvm testing

I will need distributed data for my project in the future so it was good you mentioned it cause I didn't know akka had it. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>

Re: [akka-user] Re: Deserialize ActorRef, again

In the example above by Guido Medina, he has, for instance akka-cluster = "com.romix.akka.serialization.kryo.KryoSerializer" Without this line, what akka-cluster would be and what are bound to it? Also, by default, for example, ActorRefs are handled by protobuf or java? On Friday, December

Re: [akka-user] Aggregate counts in multi-jvm testing

Exactly, I wouldn't want to add another piece to get those counters for the test. So I'm definitely gonna use akka's distributed data for this. @Konrad 'ktoso’ Malawski: I'm curious about your comment on Hazelcast (because I'm actually thinking of using it). Suppose I need to maintain

Re: [akka-user] Re: Deserialize ActorRef, again

Thanks! On Friday, December 25, 2015 at 9:39:16 AM UTC-6, Patrik Nordwall wrote: > > See reference.conf files in akka. Also included in config section of docs. > akka-cluster is mapped to a serializer that is using protobuf. ActorRef is > java serialization, but it has custom readResolve and