Hi all.

I'm using Akka 2.3.13 [I know... a bit old :(  ] with Java.

A few times I'm loosing messages (in a very intensive concurrent 
environment).  In my case a message is sent to the actor just before the 
postStop() method is called, indicating that the kill action is sent to it 
due the rebalancing logic. 

By documentation the PoisonPill is sent and the the ShardRegion actor 
(proxy) stop sending messages until the shard is completely rebalanced. 
 Following my traces the unique case I have where I loose a message is when 
I'm sending the message using the shard region actor which is physically in 
the same process where the destine actor is. I have an unique id in my 
messages the actor prints it on reception. Other commands sen't to the same 
actor from other nodes after rebalancing work fine. 

I suppose the command would be queued and then sent automatically after 
rebalancing but I can't observe this.

Have I to do something programmatically to make this work?

Many thanks in advance for any help

/Eduardo

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

Reply via email to