Re: [akka-user] [Cluster] Association failed even though cluster.leave(cluster.selfAddress) was called?

2016-07-25 Thread kraythe 
I get the idea. But does that mean I should create a top level actor like 
the /user guard but under user for all my actors and wait for the member to 
leave ? This is occurring inside of a Play Framework shutdown, so I would 
have to figure out how to orchestrate that. 

On Monday, July 25, 2016 at 2:01:52 PM UTC-5, Konrad Malawski wrote:
>
>
> Well the node leaving does nothing but shut down. The other nodes go on 
> with life of course.
>
> That's exactly the problem though: You exit the JVM before anyone has the 
> chance to even receive the Leave message.
>
> You should await the gossip message, basically:
>
> Cluster.subscribe(self, classOf[MemberRemoved])
>
> ... case MembreRemoved(address) if address == selfAddress => System.exit()
>
>
> Replied in a bit of a rush, hope you get the idea :-)
>
> You can also check out my Zen of Akka talk for a bit more wordy 
> explanation of this.
>
> -- 
> Konrad `ktoso` Malawski
> Akka  @ Lightbend 
>

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

Re: [akka-user] [Cluster] Association failed even though cluster.leave(cluster.selfAddress) was called?

2016-07-25 Thread Konrad Malawski 
Well the node leaving does nothing but shut down. The other nodes go on
with life of course.

That's exactly the problem though: You exit the JVM before anyone has the
chance to even receive the Leave message.

You should await the gossip message, basically:

Cluster.subscribe(self, classOf[MemberRemoved])

... case MembreRemoved(address) if address == selfAddress => System.exit()


Replied in a bit of a rush, hope you get the idea :-)

You can also check out my Zen of Akka talk for a bit more wordy explanation
of this.

-- 
Konrad `ktoso` Malawski
Akka  @ Lightbend 

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

Re: [akka-user] [Cluster] Association failed even though cluster.leave(cluster.selfAddress) was called?

2016-07-25 Thread kraythe 
Well the node leaving does nothing but shut down. The other nodes go on 
with life of course. 

On Monday, July 25, 2016 at 1:34:37 PM UTC-5, Konrad Malawski wrote:
>
> What do you do after you call leave?
>
> -- 
> Konrad `ktoso` Malawski
> Akka  @ Lightbend 
>
> On 25 July 2016 at 20:27:29, kraythe (kra...@gmail.com ) 
> wrote:
>
> In our code prior to shutting down a node we issue the following call. 
>
> val cluster: Cluster = Cluster.get(system)
> cluster.leave(cluster.selfAddress)
>
>
> However, despite that the other node still complains about unreachable 
> node. Any way I can stop this? 
>
> 2016-07-25 13:23:33 -0500 - [WARN] - [ReliableDeliverySupervisor] akka.tcp
> ://
> mysystem@127.0.0.1:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fruckus%40127.0.0.1%3A2552-1
>  
> -  Association with remote system [akka.tcp://ruckus@127.0.0.1:2552] has 
> failed, address is now gated for [5000] ms. Reason: [Association failed 
> with [akka.tcp://mysystem@127.0.0.1:2552]] Caused by: [Connection 
> refused: /127.0.0.1:2552]
>
> Thanks in advance!
>
> -- Robert
> --
> >> 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+...@googlegroups.com .
> To post to this group, send email to akka...@googlegroups.com 
> .
> Visit this group at https://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>
>

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

Re: [akka-user] [Cluster] Association failed even though cluster.leave(cluster.selfAddress) was called?

2016-07-25 Thread Konrad Malawski 
What do you do after you call leave?

-- 
Konrad `ktoso` Malawski
Akka  @ Lightbend 

On 25 July 2016 at 20:27:29, kraythe (kray...@gmail.com) wrote:

In our code prior to shutting down a node we issue the following call.

val cluster: Cluster = Cluster.get(system)
cluster.leave(cluster.selfAddress)


However, despite that the other node still complains about unreachable
node. Any way I can stop this?

2016-07-25 13:23:33 -0500 - [WARN] - [ReliableDeliverySupervisor] akka.tcp:
//
mysystem@127.0.0.1:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fruckus%40127.0.0.1%3A2552-1
-  Association with remote system [akka.tcp://ruckus@127.0.0.1:2552] has
failed, address is now gated for [5000] ms. Reason: [Association failed
with [akka.tcp://mysystem@127.0.0.1:2552]] Caused by: [Connection refused: /
127.0.0.1:2552]

Thanks in advance!

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

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

[akka-user] [Cluster] Association failed even though cluster.leave(cluster.selfAddress) was called?

2016-07-25 Thread kraythe 
In our code prior to shutting down a node we issue the following call.

val cluster: Cluster = Cluster.get(system)
cluster.leave(cluster.selfAddress)


However, despite that the other node still complains about unreachable 
node. Any way I can stop this? 

2016-07-25 13:23:33 -0500 - [WARN] - [ReliableDeliverySupervisor] 
akka.tcp://mysystem@127.0.0.1:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2Fruckus%40127.0.0.1%3A2552-1
 
-  Association with remote system [akka.tcp://ruckus@127.0.0.1:2552] has 
failed, address is now gated for [5000] ms. Reason: [Association failed 
with [akka.tcp://mysystem@127.0.0.1:2552]] Caused by: [Connection refused: 
/127.0.0.1:2552]

Thanks in advance!

-- Robert

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