Re: [akka-user] Am I misunderstanding throttle?

Could this be a aka-streams bug? Should I open a git bug? In-between I am using my own inferior throttle so I have a workaround final static class Tick {} public static Flow createFlow(final long throttleSecs) { Flow sourceflow = Flow.create(); Flow, BoxedUnit> flow = Flow.fromGraph(

[akka-user] Re: akka.agent and multi-agent system

Hi, I am posting my previous post again for any further respond. I want to know the contradiction between these sentences from the documentation "Agents are bound to a single storage location for their lifetime, and only allow mutation of that location (to a new state) to occur as a result of

[akka-user] Re: Connecting RabbitMQ with Java Actors

This is an Akka streams example but I have a simple project here: https://github.com/gzoller/LateRabbit In addition to providing a RabbitMQ source for streams, this project allows you to late-acknowledge messages you pull off the queue, which is a nice feature for streams. On Thursday, Februa

[akka-user] Re: akka-cluster bandtwith issue

If your messages have medium to big size you could also enable Kryo compression, besides that at this moment there is nothing else you can do on top of Akka remote, see my last post here but don't add to it please as it has grown t

[akka-user] Re: Is akka.http.scaladsl.HttpExt.cachedHostConnectionPoolHttps buggy ?

Here is a UT, which shall be helpful in recreating the error. https://gist.github.com/kingster/ff3be13feb7afb54ecc5 This behavior is specifically seen for Non 2XX response from http-servers Can someone help us here? On Thursday, March 3, 2016 at 11:30:04 PM UTC+5:30, Durga Prasana wrote: > > We

[akka-user] Override configuration with system environment variables

Hello, I am using amazon beanstalk, which allows me to define app parameters using system environment variables. If there was only a few well defined variables I would want to override, the following would be fine: http { port = 8080 port = ${?HTTP_PORT} } But there are a lot of parameters

[akka-user] akka-cluster bandtwith issue

Hello, I am a newbie in akka, and i have some questions: We have a setup from 3 servers with 1Gb network, trying tuning java akka-cluster app (1-backend and 2 -frontend with netty on top) but no success, message bandwith is going down fast on 300-320M incoming traffic on backend. Change JavaSe

[akka-user] Re: Connecting RabbitMQ with Java Actors

There is also this: https://github.com/sstone/amqp-client On Wednesday, March 2, 2016 at 4:20:08 PM UTC+1, harish...@gmail.com wrote: > > Thank you. > > On Friday, February 26, 2016 at 7:13:18 AM UTC-6, Guido Medina wrote: >> >> *Correction of previous response:* As far as my experience with Rabbi

Re: [akka-user] Akka remote communication roadmap?

In the meantime I can't stay idle so I started digging inside Netty 3 and at the moment I'm using my own Netty 3.10.6.Final (Not release yet) which replaces the Netty internal CHM (Was the one from JDK 5) There is a PR which most likely will be on 3.10.6.Final so be watching, I didn't bother to

Re: [akka-user] Async console output

Thanks so much Roland. That makes sense. As a bonus, your comment about addAttributes vs withAttributes might explain why I wasn't seeing .log output :) On Thu, Mar 3, 2016 at 12:04 AM, Roland Kuhn wrote: > Hi Richard, > > 3 mar 2016 kl. 00:24 skrev Richard Rodseth : > > This whole area of async

[akka-user] [ANN] First Call for Papers - Erlang Workshop 2016

Apologies for any duplicates you may receive. CALL FOR PAPERS === Fifteenth ACM SIGPLAN Erlang Workshop -- - Nara, Japan, September 23, 2016 Satellite event of the 21st ACM SIGPLAN International Conference on Functional

[akka-user] Problem with DistributedPubSub

I am trying to use val mediator = DistributedPubSub(context.system).mediator ClusterClientReceptionist(context.system).registerService(self) The code is similar to the one hosted @ https://www.lightbend.com/activator/template/akka-distributed-workers When I run the code, I get this exception a

[akka-user] Re: Is there a way to get the supervisor actorref of an actor?

The supervisor is always the actor's parent. I'm not aware of a direct way to get the ActorRef for the parent from outside the actor, but you could get its path using actorRef.path.parent Tal On Thursday, March 3, 2016 at 3:07:31 AM UTC+2, Remko de Jong wrote: > > Just playing around a bit an

Re: [akka-user] Async console output

Hi Richard, > 3 mar 2016 kl. 00:24 skrev Richard Rodseth : > > This whole area of async boundaries in akka streams is still very confusing > to me. I don't know what to suggest in terms of documentation, other than > numerous examples of code, with corresponding diagrams showing the resultant