Re: [akka-user] Re: Issue in Sending messages through akka cluster.

2017-05-25 Thread chaitanya
We used Single Producer and Multiple Consumer pattern On Thursday, 25 May 2017 15:56:15 UTC+5:30, chaitanya wrote: > > " The buffers in Artery are bounded and will start dropping messages if > overwhelmed " - > > which pattern would be best to resolve this issue and f

Re: [akka-user] Re: Issue in Sending messages through akka cluster.

2017-05-25 Thread chaitanya
be consumed > those messages must be buffered somewhere and that can eventually result in > out of memory. The buffers in Artery are bounded and will start dropping > messages if overwhelmed. > > Cheers, > Patrik > > On Wed, May 24, 2017 at 9:57 AM, chaitanya >

[akka-user] Re: Issue in Sending messages through akka cluster.

2017-05-24 Thread chaitanya
rom [Actor[akka://ClusterSystem/user/master_1#-495216506]] to [Actor[akka://ClusterSystem@127.0.0.1:2551/]] due to overflow of send queue, size [3072] How can On Wednesday, 24 May 2017 00:05:42 UTC+5:30, chaitanya wrote: > > Hi guys,' > I am a newbie to akka cluster and i have creat

[akka-user] Re: Detail: akka.stream.StreamTcpException: Connection failed.

2017-02-28 Thread Chaitanya Mahipath
Please provide your inputs to overcome this problem. Any help is greatly appreciated! Thanks, Chaitanya On Monday, February 27, 2017 at 4:57:34 PM UTC+5:30, Chaitanya Mahipath wrote: > > Hi Johannes, > > I tried with Http.SingleRequest as suggested but could see the following

Re: [akka-user] Re: Detail: akka.stream.StreamTcpException: Connection failed.

2017-02-27 Thread Chaitanya Mahipath
Yes. Status code, headers & the content using entity.toStrict. Thanks On Monday, February 27, 2017 at 5:06:53 PM UTC+5:30, √ wrote: > > Are you consuming your response bodies? > > -- > Cheers, > √ > > On Feb 27, 2017 12:27 PM, "Chaitanya Mahipath" > wr

[akka-user] Re: Detail: akka.stream.StreamTcpException: Connection failed.

2017-02-27 Thread Chaitanya Mahipath
d. See also the note at > http://doc.akka.io/docs/akka-http/current/scala/http/client-side/host-level.html#host-level-api > . > > HTH > Johannes > > > > On Monday, February 27, 2017 at 8:25:37 AM UTC+1, Chaitanya Mahipath wrote: >> >> Hi, >> >> I

[akka-user] Detail: akka.stream.StreamTcpException: Connection failed.

2017-02-26 Thread Chaitanya Mahipath
Hi, I am using the akka http scaladsl library to do a HTTP calls against a server. I am running a test where I have 15 threads running concurrently each making around 250 GET calls(15*250). Trying to run this test for three hours but I see that after two and half hours of execution I could see