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
a.r.a.Association(akka://ClusterSystem) - Dropping message
[ActorSelectionMessage(java.lang.String)] from
[Actor[akka://ClusterSystem/user/master_1#-495216506]] to
[Actor[akka://ClusterSystem@127.0.0.1:2551/]] due to overflow of send
queue, size [3072]
12:49:35.092 [ClusterSystem-akka.actor.default-dispatcher-3] DEBUG
a.r.a.Association(akka://ClusterSystem) - Dropping message
[ActorSelectionMessage(java.lang.String)] from
[Actor[akka://ClusterSystem/user/master_1#-495216506]] to
[Actor[akka://ClusterSystem@127.0.0.1:2551/]] due to overflow of send
queue, size [3072]
12:49:35.092 [ClusterSystem-akka.actor.default-dispatcher-3] DEBUG
a.r.a.Association(akka://ClusterSystem) - Dropping message
[ActorSelectionMessage(java.lang.String)] from
[Actor[akka://ClusterSystem/user/master_1#-495216506]] to
[Actor[akka://ClusterSystem@127.0.0.1:2551/]] due to overflow of send
queue, size [3072]
12:49:35.092 [ClusterSystem-akka.actor.default-dispatcher-3] INFO
a.r.RemoteActorRefProvider$RemoteDeadLetterActorRef - Message
[java.lang.String] from
Actor[akka://ClusterSystem/user/master_1#-495216506] to
Actor[akka://ClusterSystem/deadLetters] was not delivered. [1] dead letters
encountered. This logging can be turned off or adjusted with configuration
settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
12:49:35.093 [ClusterSystem-akka.actor.default-dispatcher-3] INFO
a.r.RemoteActorRefProvider$RemoteDeadLetterActorRef - Message
[java.lang.String] from
Actor[akka://ClusterSystem/user/master_1#-495216506] to
Actor[akka://ClusterSystem/deadLetters] was not delivered. [2] dead letters
encountered. This logging can be turned off or adjusted with configuration
settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
12:49:35.093 [ClusterSystem-akka.actor.default-dispatcher-2] DEBUG
a.r.a.Association(akka://ClusterSystem) - Dropping message
[ActorSelectionMessage(java.lang.String)] from
[Actor[akka://ClusterSystem/user/master_1#-495216506]] to
[Actor[akka://ClusterSystem@127.0.0.1:2551/]] due to overflow of send
queue, size [3072]
12:49:35.095 [ClusterSystem-akka.actor.default-dispatcher-2] DEBUG
a.r.a.Association(akka://ClusterSystem) - Dropping message
[ActorSelectionMessage(java.lang.String)] from
[Actor[akka://ClusterSystem/user/master_1#-495216506]] to
[Actor[akka://ClusterSystem@127.0.0.1:2551/]] due to overflow of send
queue, size [3072]
12:49:35.097 [ClusterSystem-akka.actor.default-dispatcher-2] DEBUG
a.r.a.Association(akka://ClusterSystem) - Dropping message
[ActorSelectionMessage(java.lang.String)] from
[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 created a sample program. I am
> using producer consumer pattern. My producer sends messages to consumer
> which are 2 seed nodes.
> The program works fine when no of messages are less like in thousands but
> the program seems to seize when i send huge no of messages to seed nodes.
>
> I have implemented artery remoting and for this i refer to ----
> http://doc.akka.io/docs/akka/2.5/java/remoting-artery.html
>
> Please find project in attached zip. Can anyone please help me out with
> this ????
>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
