[akka-user][deprecated] Akka persistence and internally stateless actors

I am adding Akka persistence to my existing application. My actors are stateless: actor's implementations have no properties. An actor receives the message, analyzes it and either forwards it to another actor or persists some data (in MongoDB or RDF store). Since actors have no state there is

[akka-user] programmatically setting guardian-supervisor-strategy

I am wondering if there are way to programmatically set guardian supervisor strategy for my actor which is a root of my actor hierarchy. I would prefer to avoid doing it in apoplication.conf -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http:/

[akka-user] Creating multiple instances of ActorSystem

I am wondering if it is possible to create multiple instances of ActorSystem within a single JVM? I create my systems as ActorSystem actorSystem = ActorSystem.create("mySystem", ConfigFactory.load ().getConfig("mySystem")); and when I call startTime() of each system created it seems to indicat

Re: [akka-user] Strange actor behavior with Akka Spring Integration

d up on how to split up an application into > actors and which messaging patterns are frequently needed—there happen to > be multiple nice books on this topic (e.g. Vaughn Vernon’s «Reactive > Messaging Patterns with the Actor Model» or Y.T.’s «Reactive Design > Patterns»). >

Re: [akka-user] Strange actor behavior with Akka Spring Integration

priate destination > > def receive = { > > case msg => > > if (shallGoTo1(msg)) actor1 ! msg > > else if (shallGoTo2(msg)) actor2 ! msg > > else if (shallGoTo3(msg)) actor3 ! msg > > } > > > > ... > > } > > > &

Re: [akka-user] Strange actor behavior with Akka Spring Integration

ors as children of the supervisor which essentially allows only one router. On Friday, August 19, 2016 at 10:39:50 PM UTC-4, Justin du coeur wrote: > > On Fri, Aug 19, 2016 at 4:23 PM, Mark Kaberman > wrote: > >> The fact that actor names are generated by Akka is also a concern. &g

[akka-user] Strange actor behavior with Akka Spring Integration

I am observing strange behavior with actors which are created using Akka Spring integration. I think I can explain this behavior, but I am not sure how to fix it. My router is defined in application.conf as AkkaDemo{ akka.actor.deployment { /actorRouter{ router = round-robin

Re: [akka-user] Router path in Akka config

: > > This looks like where Akka Streams might be a better fit? See this chapter > in the streams docs: > http://doc.akka.io/docs/akka/2.4/scala/stream/stream-parallelism.html > > -Endre > > On Fri, Aug 19, 2016 at 5:27 PM, Mark Kaberman > wrote: > >> In my case sin

Re: [akka-user] Router path in Akka config

> Roland > > 19 aug. 2016 kl. 16:23 skrev Mark Kaberman >: > > Actually I only need 3 entry instead of 5 and I need to name my routers > differently: > /actor1/router1/ > /actor1/router1/actor2/router2 > /actor1/router1/actor3/router2 > > but the point is still v

[akka-user] Re: Router path in Akka config

19, 2016 at 10:00:21 AM UTC-4, Mark Kaberman wrote: > > When I define a router in Akka's application.conf I always need to specify > the router path. If I have multiple possible routes the messages travel in > my application the configuration file may become very complicated.

[akka-user] Router path in Akka config

When I define a router in Akka's application.conf I always need to specify the router path. If I have multiple possible routes the messages travel in my application the configuration file may become very complicated. An example: I have three actors in my system: actor1, actor 2 and actor3. Act

Re: [akka-user] Meaning of the $ in the actor's path

t's best practice to actually explicitly name your actor btw. > > On 19 Aug 2016 00:41, "Mark Kaberman" > > wrote: > >> I am creating my Akka actors via Spring integration as described here >> <https://github.com/typesafehub/activator-akka-java-spring

[akka-user] Meaning of the $ in the actor's path

I am creating my Akka actors via Spring integration as described here . When I look at my actors paths I always see the $ followed by the letter. For example If I create an actor and send the message as rootActor = system.actorOf(Spring

Re: [akka-user] Akka Spring integration seems to slowly leak memory

ctorOf(ActorCell.scala:374) at org.mark.demo.BaseActor.sendMessage(BaseActor.java:67) at org.mark.demo.RootActor.onReceive(RootActor.java:38)Enter code here... On Friday, July 22, 2016 at 5:03:32 AM UTC-4, rkuhn wrote: > > 21 juli 2016 kl. 18:39 skrev Mark Kaberman >: > > I was able to

Re: [akka-user] Akka Spring integration seems to slowly leak memory

tor gets stopped.) >- What is the context in which the sendAkkaMessage method is called? >How many of these contexts exist? > > > Regards, > > Roland > > 14 juni 2016 kl. 14:39 skrev Mark Kaberman >: > > It does not. > > On Tuesday, June 14, 20

Re: [akka-user] Akka Spring integration seems to slowly leak memory

It does not. On Tuesday, June 14, 2016 at 8:14:20 AM UTC-4, √ wrote: > > Is supervision triggering? (i.e. restarts, possibly creating new beans)? > > On Tue, Jun 14, 2016 at 2:03 PM, Mark Kaberman > wrote: > >> I added the static instantiation counter to my a

Re: [akka-user] Akka Spring integration seems to slowly leak memory

create an actor. How > do you see that? > > On Fri, Jun 10, 2016 at 10:43 PM, Mark Kaberman > wrote: > >> I debugged my application and it seems to be a bug in Akka: >> >> My routers are defined similarly to each other as >> /myActor/ { >> dispatche

Re: [akka-user] Akka Spring integration seems to slowly leak memory

those MyActor > instances. > > -- > Cheers, > √ > On Jun 10, 2016 6:03 PM, "Mark Kaberman" > > wrote: > >> Isn't the code: >> >> if (child != null && child.isDefined()) { >>actor = child.get(); >> } >> &g

Re: [akka-user] Akka Spring integration seems to slowly leak memory

be processing different vertices? Will they be shut down as well? On Friday, June 10, 2016 at 10:48:48 AM UTC-4, √ wrote: > > If you create new actors continually and never stop any of them then you > have by design got a leak. > > -- > Cheers, > √ > On Jun 10, 2016 4:35 PM

Re: [akka-user] Akka Spring integration seems to slowly leak memory

ask) and exit onReceive. Regards, Mark On Friday, June 10, 2016 at 10:27:25 AM UTC-4, √ wrote: > > Hi Mark, > > Where are you stopping your actors? > > -- > Cheers, > √ > On Jun 10, 2016 2:55 PM, "Mark Kaberman" > > wrote: > >> I have Ak

[akka-user] Akka Spring integration seems to slowly leak memory

I have Akka application which is essentially traverses a very large tree where each vertex processing is done by an individual actor. Different kinds of vertices are processed by different actors. The actors are implemented as prototype Spring beans (they are derived from the same abstract cla

[akka-user] Detecting when all children actors are finished

I am trying to find a way to find out when all children actors are finished working (processed all the messages in their respective queues). Think about graph traversal when each vertex discovery requires its own actor. The depth of the tree is finite and known and each level is requires its ow

[akka-user] Using different names for application.conf

My application consists out of multiple services (daemons) which unfortunately have to share the location for configuration files. I would prefer to avoid maintaining single application.conf which is shared by all services due to logistical reasons. I also cannot package individual application.

[akka-user] Re: Modify supervisor startegy for root actor

angerous" work and handle > the child's failure appropriately. The second choice is not letting the > exception to escape receive method: catch it and send a message that > describes the error to the Spring controller. > > Hope that helps, > Rafał > > W dniu wtorek

[akka-user] Modify supervisor startegy for root actor

I have Spring MVC controller class in my application which creates top level Akka actor (via Spring). When this actor throws an exception I expect it to be handled by the controller, but in my case the actor simply times out after 5 sec. I tried to implement my own SupervisorStrategyConfigurat

Re: [akka-user] Mixing local and remote actor instances

> > http://doc.akka.io/docs/akka/2.3.4/general/configuration.html > > Does that help? > > > On Fri, Aug 1, 2014 at 5:24 PM, Mark Kaberman > wrote: > >> I am trying to figure out if is possible to configure Akka to run x >> number of local and y number of r

[akka-user] Mixing local and remote actor instances

I am trying to figure out if is possible to configure Akka to run x number of local and y number of remote instances of the same actor (basically combination of scale up and scale out approaches). The documentation is clear about how to configure local and remote actors, but I couldn't find any