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

2018-03-14 Thread Mark Kaberman
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

2017-02-06 Thread Mark Kaberman
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: >>

[akka-user] Creating multiple instances of ActorSystem

2016-09-21 Thread Mark Kaberman
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

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

2016-08-19 Thread Mark Kaberman
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 <mkab...@gmail.com > > wrote: > >> The fact that actor names are generated by A

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

2016-08-19 Thread Mark Kaberman
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 =

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

2016-08-19 Thread Mark Kaberman
: > > 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 <mkab...@gmail.com > > wrote:

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

2016-08-19 Thread Mark Kaberman
Roland > > 19 aug. 2016 kl. 16:23 skrev Mark Kaberman <mkab...@gmail.com > >: > > 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 > >

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

2016-08-19 Thread Mark Kaberman
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. An

[akka-user] Router path in Akka config

2016-08-19 Thread Mark Kaberman
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.

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

2016-08-18 Thread Mark Kaberman
est practice to actually explicitly name your actor btw. > > On 19 Aug 2016 00:41, "Mark Kaberman" <mkab...@gmail.com > > wrote: > >> I am creating my Akka actors via Spring integration as described here >> <https://github.com/typesafehub/activator-a

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

2016-08-18 Thread Mark Kaberman
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 =

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

2016-07-22 Thread Mark Kaberman
ll.actorOf(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 <mkab...@gmail.com > &

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

2016-06-14 Thread Mark Kaberman
actor 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 <mkab...@gmail.com > >: > > It does not. > &g

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

2016-06-14 Thread Mark Kaberman
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 <mkab...@gmail.com > > wrote: > >> I added the static instantiat

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

2016-06-14 Thread Mark Kaberman
> do you see that? > > On Fri, Jun 10, 2016 at 10:43 PM, Mark Kaberman <mkab...@gmail.com > > wrote: > >> I debugged my application and it seems to be a bug in Akka: >> >> My routers are defined similarly to each other as >> /myActor/ { >> di

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

2016-06-10 Thread Mark Kaberman
ocessing 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, &q

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

2016-06-10 Thread Mark Kaberman
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" <mkab...@gmail.com > > wrote: >

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

2016-06-10 Thread Mark Kaberman
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

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

2015-04-01 Thread Mark Kaberman
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

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

2015-02-02 Thread Mark Kaberman
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

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

2014-10-15 Thread Mark Kaberman
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, 14 października 2014 22:03:19 UTC+2 użytkownik Mark Kaberman napisał: I have Spring MVC controller class in my application which

[akka-user] Modify supervisor startegy for root actor

2014-10-14 Thread Mark Kaberman
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

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

2014-08-04 Thread Mark Kaberman
/general/configuration.html Does that help? On Fri, Aug 1, 2014 at 5:24 PM, Mark Kaberman mkab...@gmail.com javascript: wrote: 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

[akka-user] Mixing local and remote actor instances

2014-08-01 Thread Mark Kaberman
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