[akka-user] GraphDSL.create is not visible for IDE

Hi. I updated my project to akka-http-experimental 2.0.1 I see in documentation there are a lot of examples with GraphDSL.create() but for some strange reason Intellij does not find create method in GraphDSL object in scalaDSL (I checked, it uses the latest artifact). I wonder, is it an Idea

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

You're in a distributed system – how would you do it there? "The Akka way" of doing it is messaging :-) Send a message to the "cluster actor", which each JVM has,  from the same sender, collect the replies, once you got all of them (and you know, because you know how many questions you've sent),

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

Is there any way to combines variables from different jvm's in multi-jvm testing? More concretely, suppose each jvm has a counting variable (which, for eg, counts the number of jobs that have been sent to them), and I want to check that their sums is equal to some number (for eg. the total

Re: [akka-user] Feedback on BackoffSupervisor

Hi Henry, > 18 dec 2015 kl. 16:58 skrev Henry Mai : > > > The only Actor that can supervise another Actor must be the one that has > > created it, anything else would be rather pointless because only the parent > > can react to the termination of its child Actor by

[akka-user] Update http routes

Hi, for my scenario, I need to modify http routes dynamically at runtime by one of the actors. Can I do it without restarting http server? Regards, Greg -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

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

Is there a difference between doing serializers { java = "com.romix.akka.serialization.kryo.KryoSerializer" } and serializers { myown = "com.romix.akka.serialization.kryo.KryoSerializer" } serialization-bindings { "java.io.Serializable" = myown } On Saturday, December 19, 2015 at

Re: [akka-user] Re: Wikipedia presence

Cool, thanks! :-) On Thu, Dec 24, 2015 at 12:26 AM, Ilya Korniyko wrote: > Created an https://en.wikipedia.org/wiki/Reactive_Streams article. > > On Wednesday, December 26, 2012 at 12:42:15 AM UTC+2, Nicholas Sterling > wrote: >> >> After reading about Akka's dataflow

[akka-user] Re: Akka PersistenceQuery java example

Use same persistenceId in PersistentActor and the query persistence Em quinta-feira, 24 de dezembro de 2015 09:02:53 UTC-3, Jan-Terje Sørensen escreveu: > > Any suggestion on how to solve it? > -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Re: Akka PersistenceQuery java example

Any suggestion on how to solve it? -- >> 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

Re: [akka-user] Update http routes

Not built in but doable, see  https://github.com/movio/spray-dynamic-routing-example for inspiration. You should be able to translate it to Akka HTTP. --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 24 December 2015 at 10:17:23, greg.kam...@bcgdv.com (greg.kam...@bcgdv.com) wrote: Hi,

[akka-user] Re: Akka PersistenceQuery java example

The thing that is not working is to read the events from the journal. You can the se work in progress code here . This is how i persist my events: public class

[akka-user] Re: Akka PersistenceQuery java example

Your actor has a fixed persistenceId, "sample-id-1". You are trying read events from "persistentActor-4-java" persistence Id, it never will works. Em quinta-feira, 24 de dezembro de 2015 08:26:30 UTC-3, Jan-Terje Sørensen escreveu: > > The thing that is not working is to read the events from

[akka-user] Quarantined?

Hi, all: I have read http://doc.akka.io/docs/akka/2.4.0/scala/remoting.html#Lifecycle_and_Failure_Recovery_Model It says that the link will go to Quarantined state when Catastrophic communication failure: Remote DeathWatch trigger System message delivery failure

[akka-user] Re: akka-http how to set global timeout for http services

Hello I see that nobody answer to this Any news ? On Tuesday, November 10, 2015 at 8:04:37 PM UTC+2, Richard Grossman wrote: > > Hi > > I need to make a http service that must end the process in limited amount > of time. > Meaning if the process take longer than 0.5s then I reply an error code

Re: [akka-user] Re: akka-http how to set global timeout for http services

Sorry, I've misread your question - you mean a request-timeout. I'm not sure from the top of my head, will revisit this after christmas dinner. I quickly grepped and it may be missing still, could you open a ticket for this? On Thu, Dec 24, 2015 at 3:02 PM, Konrad Malawski <

Re: [akka-user] Re: akka-http how to set global timeout for http services

Grep the rederence.conf of Akka http core for 'idle-timeout'. We also have it documented AFAIR, but not at my laptop now. On Dec 24, 2015 15:00, "Richard Grossman" wrote: > Hello > > I see that nobody answer to this > Any news ? > > On Tuesday, November 10, 2015 at 8:04:37

[akka-user] Re: Akka PersistenceQuery java example

I have tryed with setting same id's, but still not able to list events. Are you able to show some code on how to solve this? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >>