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

2017-05-26 Thread Patrik Nordwall
Work pulling (see my previous link) might be a good choice. Note that it's not only about that the end consumers might not consume fast enough, it's also anything on the way there, such as serialization and deserialization (which I think is your bottleneck). On Thu, May 25, 2017 at 1:16 PM,

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 faster? > > > On Wednesday,

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

2017-05-25 Thread chaitanya
" The buffers in Artery are bounded and will start dropping messages if overwhelmed " - which pattern would be best to resolve this issue and faster? On Wednesday, 24 May 2017 17:54:11 UTC+5:30, Patrik Nordwall wrote: > > You have to implement some flow control, such as as using the "Work >

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

2017-05-24 Thread Patrik Nordwall
You have to implement some flow control, such as as using the "Work Pulling" pattern , throttling, or send acknowledgment messages back from the consumer. If producer is sending messages at a higher rate

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

2017-05-24 Thread chaitanya
Following is the console output of my program it says Dropping messages due to overflow of send queue. How to solve this? GET Messages >>> Content GET Messages >>> Content 12:49:35.091 [ClusterSystem-akka.actor.default-dispatcher-3] DEBUG