Re: [akka-user] Explaining AKKA Thread Pool Execturor Config parameters

Hi Maatary, On Sun, Oct 11, 2015 at 9:27 PM, Maatary Okouya wrote: > Hi, > > As I understood that the fork-join-executor is the default dispatcher > when non is provided when creating the actor system > Can someone explain me the following: > > >1.

Re: [akka-user] Explaining AKKA Thread Pool Execturor Config parameters

Understood, Many thanks. On Mon, Oct 12, 2015 at 6:08 AM, Viktor Klang wrote: > > > On Mon, Oct 12, 2015 at 12:00 PM, Maatary Okouya > wrote: > >> Thank you victor. >> >> However, >> >> 1 - does it means that akka configuration is not related to

Re: [akka-user] Combine FSM[S, D] and DiagnosticActorLogging

Hi Patrik, I tried your suggestion, unfortunately I get the same compile time error )-: object FSMDoubleExtendDemo { def props(name: String): Props = Props(new FSMDoubleExtendDemo()) sealed trait Params case object Empty extends Params sealed trait State case object State1 extends

Re: [akka-user] Explaining AKKA Thread Pool Execturor Config parameters

On Mon, Oct 12, 2015 at 12:44 PM, Maatary Okouya wrote: > Just to be clear, the meaning of parallelism is not stricto sensus. In > other words, when i think parallelism, i think parallel execution. While > given that we are not at 1 thread per OS reported processor, but

[akka-user] akka.actor.ActorNotFound: Actor not found for: ActorSelection[Anchor(akka.tcp://DistIdx@dist-index:2710/), Path(/user/databaseServer/index:my-index)]

Running some stress tests on my code produces the following: 2015-10-12 15:38:06.301UTC ERROR[DistIdx-akka.actor.default-dispatcher-22] [akka.tcp://DistIdx@dist-index:2720/user/driverActor] o.d.a.e.i.ActorExtImpl - Failed to locate index akka.actor.ActorNotFound: Actor not found for:

Re: [akka-user] [akka-persistence] Hihgest sequence number and deleteMessages in third-party journal.

It should keep track of the highest used sequence number, also after delete of all events. That is not documented yet. We intend to do so and also enforce it with the TCK. https://github.com/akka/akka/issues/18559 /Patrik On Sat, Oct 10, 2015 at 11:43 AM, Evgeny Shepelyuk

[akka-user] Re: How to construct a type parameterized Actor with a ClassTag?

I found a basic way to do this by manually passing the ClassTag. It is not very pretty but it works: import akka.actor._ import scala.reflect.ClassTag class MyActor[V](size: Int, default: V, ct: ClassTag[V]) extends Actor { // Array of given size filled with given default value val

[akka-user] Event-sourcing with aka-persistence

Hello, I am new in Akka and I am trying to develop some mini project to test some things (akka, rx, cqrs, es etc..) I think I understand the concept of cqrs/es and how it fit to akka. My problem is probably more theoretical than technical. Let's say, I have class Player, which has several

[akka-user] Re: [Akka Streams] Sink vs Flow (or: committing offsets after writing to Kafka)

On Monday, 12 October 2015 10:03:06 UTC-7, Julian Howarth wrote: > > Have you looked at reactive-kafka: > https://github.com/softwaremill/reactive-kafka ? > I have looked at reactive-kaka and am following some discussions on Gitter on the subject. > We use the method documented in the

[akka-user] Re: [Akka Streams] Sink vs Flow (or: committing offsets after writing to Kafka)

Have you looked at reactive-kafka: https://github.com/softwaremill/reactive-kafka ? We use the method documented in the Manual Commit section of that page which works well for us. Basically, it automatically commits some configurable period of time after your processing of the message is

Re: [akka-user] [akka-persistence] Hihgest sequence number and deleteMessages in third-party journal.

It would be great if you do that. Thanks /Patrik mån 12 okt. 2015 kl. 20:52 skrev Evgeny Shepelyuk : > Thank you for the answer. > Will it be possible to contribute to TCK if I be able to write proper test > cases ? > > понеділок, 12 жовтня 2015 р. 15:47:37 UTC+3 користувач

Re: [akka-user] [akka-persistence] Hihgest sequence number and deleteMessages in third-party journal.

Thank you for the answer. Will it be possible to contribute to TCK if I be able to write proper test cases ? понеділок, 12 жовтня 2015 р. 15:47:37 UTC+3 користувач Patrik Nordwall написав: > > It should keep track of the highest used sequence number, also after > delete of all events. That is

Re: [akka-user] Re: is there a way to know when *really* an actor has stopped

well, it could, but requires more work and it is more complex than having any actor .watch() for events. Especially in my case that I need to watch for termination across the cluster, I would need a round trip to all parents (where as now I am just doing the round trip to the actors straight

Re: [akka-user] [akka-http] mapInnerRoute is not working

Hi Jack, please don't double post questions to multiple forums at the same time, it makes tracking if something is resolved or not yet much harder for us. Or post the solution on the relevant cross-posted threads once you have found it, so others can benefit from fiding it, thanks a lot in

Re: [akka-user] Explaining AKKA Thread Pool Execturor Config parameters

Oh thanks. Great material On Mon, Oct 12, 2015 at 6:53 AM, Viktor Klang wrote: > > > On Mon, Oct 12, 2015 at 12:44 PM, Maatary Okouya > wrote: > >> Just to be clear, the meaning of parallelism is not stricto sensus. In >> other words, when i