[akka-user] Java8 .stream() or .parallelStream() in Actors

I've just started experimenting with akka. (Still using akka with java8) I've been working on something for a few weeks. One of the things that i am not sure about is whether to use .stream() or .parallelStream(). Since actors themself are already threaded. Is it beneficial to again use

Re: [akka-user] Please help: is it Akka SupervisorStrategy bug or configuration issue?

You're welcome ons 11 maj 2016 kl. 22:44 skrev Yan Pei : > Patrik, > > Your suggestion makes a lot of sense. Yes eventually the supervisor > handled the exception. Yesterday I didn't wait long enough and stop the > application before the supervisor can handle it. > > Thanks

Re: [akka-user] Mock framework for Akka actors

Take a look at Akka akka-testkit’s `TestProbe` and its auto pilot stuff. Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > On 11 May 2016, at

[akka-user] Re: Mock framework for Akka actors

Is it ok to use Mockito for mocking? On Wednesday, 11 May 2016 08:44:30 UTC-5, Amruta wrote: > > We are using Akka concept for batch processing. The actors talk to > different database and process large amount of data. Is there a way to test > this system, without connecting to database, by

Re: [akka-user] Please help: is it Akka SupervisorStrategy bug or configuration issue?

Patrik, Your suggestion makes a lot of sense. Yes eventually the supervisor handled the exception. Yesterday I didn't wait long enough and stop the application before the supervisor can handle it. Thanks a lot for your helps. Yan On Wednesday, May 11, 2016 at 1:46:35 AM UTC-5, Patrik

Re: [akka-user] Native LevelDB crashes Akka tests

Thanks for checking it Patrick. I wonder if something changed in sbt that could cause it (a desperate guess). On Monday, May 9, 2016 at 8:39:24 AM UTC-4, Patrik Nordwall wrote: > > It looks like we have not changed anything in akka-persistence (and it's > leveldb journal) between those

Re: [akka-user] Inspectable Inboxes? Resolving a large state processing problem.

i don't think that maintaining a hazelcast map is 'un-akka' at all. it sounds like it works for you. what are you hoping to improve, specifically? what is it about hazelcast that causes you pain? what does "pure-non hazelcast approach" mean? you need to track some state (submitted jobs)

[akka-user] Re: How to send a message in a reactive stream from the Sink to the Source in a web socket connection

Thanks Flavio, that would be awesome! El martes, 10 de mayo de 2016, 4:26:32 (UTC-3), Flavio escribió: > > Hello Frederico > > I have seen your question/topic > and will post > the code there (today). > > have fun! > > Flavio > >

[akka-user] Wrapping ask pattern in messaging gateway

In Vaughn Vernon's book "Reactive Messaging Patterns with the Actor Model" i discovered the "Messaging Gateway" pattern to implement a transient actor lifetime for actors with aggregate (in a DDD sense) characteristics which was exactly what i needed for a CQRS style architecture based on

Re: [akka-user] Akka Persistence - Use only Snapshots

Hi Filippo, thanks a lot for your insights. This was very helpful. Cheers On Monday, May 9, 2016 at 5:46:50 PM UTC+2, Filippo De Luca wrote: > > Hi Peter, > Assuming the actor has a status represented by a case class MyActorStatus. > You need a way to write this status out and be able to

Re: [akka-user] Akka Remoting Ports

Perhaps a more definitive answer: what you are asking for is not possible because that would require binding to the listen port also for the outgoing connections, but that is not legal (it results in a BindException saying “Address already in use”). This is why the source port of TCP

[akka-user] Re: Error when scheduling akka system with quartz scheduler

Do I need to refresh/reload the actorSystem in some way? On Tuesday, 10 May 2016 09:29:07 UTC-5, Amruta wrote: > > I have scheduled a task that the actors carry out at a scheduled > time(every 5 minutes). When I deploy my app the first time it runs fine but > on the second and consequent runs

[akka-user] Mock framework for Akka actors

We are using Akka concept for batch processing. The actors talk to different database and process large amount of data. Is there a way to test this system, without connecting to database, by mocking the response for the actors? I was thinking of using Wiremock or some other framework but

Re: [akka-user] Re: Akka Remoting Ports

Waiting to hear what? On Wed, May 11, 2016 at 4:34 AM, wrote: > Hi, > Still waiting to hear, could anybody please give me some hint > > Regards > > > > On Tuesday, May 10, 2016 at 6:29:03 PM UTC+5, enovo...@gmail.com wrote: >> >> Hi, >> I have two remote actor systems

Re: [akka-user] really strange MatchError - scala.MatchError: None (of class scala.None$)

I investigated the situation further and found that the MatchError only happens if some newly introduced graph construction code is used. In particular, I have a graph that is created with the Scala GraphDSL and that has a custom shape. If that graph is imported into another graph (in

[akka-user] Re: Akka Remoting Ports

Hi, Still waiting to hear, could anybody please give me some hint Regards On Tuesday, May 10, 2016 at 6:29:03 PM UTC+5, enovo...@gmail.com wrote: > > Hi, > I have two remote actor systems deployed on two different cloud platforms, > one deployed on Google (port 80) and the other one on AWS

[akka-user] Re: Akka Remoting Ports

Hi Abud, That's how TCP sockets work, you connect to a specific port, but the source-port your connection "comes from" is chosen randomly. See for example this SO question for someone asking the same question but about browser connections:

[akka-user] really strange MatchError - scala.MatchError: None (of class scala.None$)

Hi all, after some restructuring of an Akka stream application I get a really strange match error: scala.MatchError: None (of class scala.None$) at scala.collection.mutable.MapLike$class.getOrElseUpdate(MapLike.scala:192) ~[scala-library-2.11.8.jar:?] The called method

Re: [akka-user] Please help: is it Akka SupervisorStrategy bug or configuration issue?

On Tue, May 10, 2016 at 9:47 PM, Yan Pei wrote: > Thank you Patrik, > > The reason I put Thread.sleep() here is to simulate the real use case in > which our KidActor needs to call a third party API and throw an Exception > if something goes wrong(like unauthorized token).

Re: [akka-user] Re: [Akka-stream|http] - How to close a flow with killswitch from outside?

Hi, What I thought was if the websocket connection gets closed, then it should be cleaned from anywhere that has its ActorRef. Only because the actor will be dead and it still will receive messages(dead letters) which I guessed, when the system goes under pressure/load then it can lead to