[akka-user] Re: Akka cookie from HttpResponse

Hi Rafal Thank for your reply, however, this still does not have the cookie value I'm expecting. I'm expecting something like #HttpOnly_.apple.com TRUE / TRUE 0 cookie_key cookie_value (this is generated by curl cookie jar) However from the set-cookie header, the result I've gained only

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

Here . My apologies: it wasn't Roland, but Konrad Malawsky. The issue I am investigating is that if I use multiple routers in my path Akka creates huge amount of actor's class instances and the system runs out of memory If I have

Re: [akka-user] Supervisor strategy with futures within child actor

This is true, and unsurprising when you think about it: Futures run outside the thread context of the Actor. This is why it's so important to *not* change the Actor's state in a mapped callback from the Future. The Exception in the Future isn't in the Actor's call stack, so it can't be caught

[akka-user] Cluster Metrics on Windows

Using Akka 2.4.9 and Windows 10 I am unable to get CPU cluster metrics, I can only get HeapMemory metrics. Running the same code on a Ubuntu server I get both CPU metrics and Heap metrics. I am using the factorial example located at:

[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 =

[akka-user] Supervisor strategy with futures within child actor

It seems that the supervision doesnt react on exceptions within futures. For example http requests return futures, how do i escalate any exceptions to my guardian/parent actor? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] [Akka-HTTP] How do I drop the connection from the Server?

FYI for readers of this thread: We chatted this over on twitter https://twitter.com/derekwyatt/status/766652868052918272 In general it is not legal HTTP to not send a response code, so the typical proper way is to Connection: close and a 500 response code I'd say. The really killing a connection

Re: [akka-user] [akka-streams] Wrapping one flow with another while keeping the inner's materialized value

Hi Itamar, First of all, I think there is already a timing stage somewhere in akka-stream-contrib (https://github.com/akka/akka-stream-contrib), but I might be wrong. As for using flatMapConcat, apart from the issue that it does not give you the materialized value, it is also slower than a

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

You can do all these with streams, plus backpressure. On Fri, Aug 19, 2016 at 6:12 PM, Mark Kaberman wrote: > Akka Streams may alleviate the scale issues some, but I doubt they will > solve it completely. I still would prefer to be able to use routers since I > can play

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

Akka Streams may alleviate the scale issues some, but I doubt they will solve it completely. I still would prefer to be able to use routers since I can play with number of instances, use pinned dispatcher for slow actors etc. On Friday, August 19, 2016 at 11:53:49 AM UTC-4, drewhk wrote: > >

[akka-user] [akka-streams] Wrapping one flow with another while keeping the inner's materialized value

Hi everyone, I'm trying to write a function that wraps an arbitrary flow with another flow that performs a side-effect: measures the execution time of the inner flow. I'm also trying to avoid writing a custom GraphStage to do this. So far, I've come up with this: def measuredFlow[In,

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 single actor may not be fast

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

In my case single actor may not be fast enough. My actors sometimes deal with fairly large latencies depending where in the path they are. To expand on my example it is possible that actor 2 does not receive many messages from actor1 and capable of processing them quickly, but it receives large

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

Why do you conflate the route structure (i.e. the routing hops) with the supervisor hierarchy? This is usually a bad idea. Instead, create your three actors as children of a supervisor that introduces them to one another—and only introduce Routers once you have benchmarked that a single actor

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

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 valid: I need to accommodate for all possible path permutations in my routers definition. On Friday, August

[akka-user] [ANNOUNCE] Akka 2.4.9 Released!

Dear hAkkers, We—the Akka committers—are pleased to be able to announce the availability of Akka 2.4.9. We would like to thank everyone who tested the Release Candidates, such that now we’re confident in releasing this version. This version is focused on Akka HTTP and Akka Streams

[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.

[akka-user] scheduleOnce() not fire message?

Hi, I use the following statements in preStart() to fire a message at a specific time: Logger.info("delaying " + d ) ; context().system().scheduler().scheduleOnce(d, self(), Tick.tick, getContext().dispatcher(), this.self()); In my test case, it works well. But when run in Play 2.5.4, I see

Re: [akka-user] Basic Akka stream server not receiving data sent by client

Thanks Endre, Helpers or a couple of lines in the Akka documentation. Which BTW is a great resource. -chhil On Fri, Aug 19, 2016, 4:47 PM Akka Team wrote: > Hi, > > On Fri, Aug 19, 2016 at 12:41 PM, murtuza chhil wrote: > >> Thank you for the

Re: [akka-user] Basic Akka stream server not receiving data sent by client

Hi, On Fri, Aug 19, 2016 at 12:41 PM, murtuza chhil wrote: > Thank you for the pointer. > > Changed it to the following > ```java > final List options = new ArrayList() > ; > Source > serverSource = Tcp > >

Re: [akka-user] Basic Akka stream server not receiving data sent by client

Thank you for the pointer. Changed it to the following ```java final List options = new ArrayList(); Source serverSource = Tcp .get(system).bind("127.0.0.1",6000,100,options,true,Duration.create(5, TimeUnit.MINUTES)); ``` Now I get

Re: [akka-user] Re: How do I implement "Lookup or Create actor" pattern

Hi, I think nowadays your problem is solved by cluster sharding, which, apart from the crate-or-lookup pattern provides resilience and scaling: http://doc.akka.io/docs/akka/2.4/scala/cluster-sharding.html -Endre On Fri, Aug 19, 2016 at 11:41 AM, Manh Ha VU wrote: > Hi

[akka-user] Re: How do I implement "Lookup or Create actor" pattern

Hi Thibault, So finally, how did you implement this requirement of yours? I'm facing on a similar problem in which each actor is a Facebook Messenger user. I don't know in advance if these users exist so that I have to create a new actor if one does not exist. Thanks, Manh-Ha On

Re: [akka-user] What means of akka cluster roles leader?

HI Yutao, On Mon, Aug 15, 2016 at 2:26 PM, Yutao Shuai wrote: > > > Thanks

Re: [akka-user] Basic Akka stream server not receiving data sent by client

On Sun, Aug 14, 2016 at 2:18 PM, murtuza chhil wrote: > Hi, > > I have a simple client that reads a csv file and send it across. When I > have a netcat server I can see the data come through. > > However when I have a Akka stream based server I do see the connection but > I

Re: [akka-user] What happened if leader become unreachable in the cluster

Hi Yutao, The leader is not a user concern, why do you ask? In general, the leader is "elected" once the cluster state is convergent. This "election" is more or less implicit and it is a pure function of the membership ring. It has nothing to do with DOWN-ing, only in the sense that DOWN-ing

Re: [akka-user] Do we rename the actor instance's name.

Hi Vishal, It is not possible to change the name of an actor as it is part of a unique identifier during its lifetime. Why do you even need to change it? -Endre On Fri, Aug 12, 2016 at 12:09 AM, Justin du coeur wrote: > The system certainly doesn't do so normally; I don't