Re: [akka-user] Unit test for Persistent Actor Replay

2016-12-01 Thread Roland Kuhn 
Well, it is solved in Akka Typed: removing system.actorOf() and system.stop() 
is the only way to "solve" this. The reason is that the semantics of these 
methods are incompatible with the distributed nature of the ActorSystem.

Regards, Roland 

Sent from my iPhone

> On 2 Dec 2016, at 08:12, Viktor Klang  wrote:
> 
> Good question!
> 
> The notification of its death hadn't reached the closest of kin (its parent) 
> so they hadn't even put it in the ground when you proposed to create a new 
> one and call it the same thing, so they (rightfully so) objected to that 
> suggestion.
> 
> This trips people up every now and then, but I've never seen a proposal to 
> solve it.
> 
> -- 
> Cheers,
> √
> 
> 
>> On Dec 2, 2016 02:44, "Richard Rodseth"  wrote:
>> We have a unit test for a persistent actor, which instantiates a second 
>> instance after waiting for termination of the first.
>> 
>> watch(definitionReader)
>> 
>> system.stop(definitionReader)
>> 
>> expectTerminated(definitionReader)
>> 
>> val notificationDefinitionReader2 = system.actorOf(actorProps, actorName)
>> 
>> This test fails intermittently on Bamboo
>> 
>> actor name [name1] is not unique!
>> Any ideas? 
>> 
>> 
>> -- 
>> >> 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.

-- 
>>  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] Unit test for Persistent Actor Replay

2016-12-01 Thread Viktor Klang 
Good question!

The notification of its death hadn't reached the closest of kin (its
parent) so they hadn't even put it in the ground when you proposed to
create a new one and call it the same thing, so they (rightfully so)
objected to that suggestion.

This trips people up every now and then, but I've never seen a proposal to
solve it.

-- 
Cheers,
√

On Dec 2, 2016 02:44, "Richard Rodseth"  wrote:

> We have a unit test for a persistent actor, which instantiates a second
> instance after waiting for termination of the first.
>
> watch(definitionReader)
>
> system.stop(definitionReader)
>
> expectTerminated(definitionReader)
>
> val notificationDefinitionReader2 = system.actorOf(actorProps, actorName)
>
> This test fails intermittently on Bamboo
>
> actor name [name1] is not unique!
>
> Any ideas?
>
>
> --
> >> 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] Unit test for Persistent Actor Replay

2016-12-01 Thread Richard Rodseth 
We have a unit test for a persistent actor, which instantiates a second
instance after waiting for termination of the first.

watch(definitionReader)

system.stop(definitionReader)

expectTerminated(definitionReader)

val notificationDefinitionReader2 = system.actorOf(actorProps, actorName)

This test fails intermittently on Bamboo

actor name [name1] is not unique!

Any ideas?

-- 
>>  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] How to pass Ip/Port info of all runing services to the Akka node dynamically.

2016-12-01 Thread Nitin Jadon 
 We are running Akka with Docker image and want to pass all the running 
Akka Docker's IP/Port info in case of addition on new Docker image.

our application.conf file is defined as per below 

 

akka 
 {


 actor 
  {
provider = "akka.cluster.ClusterActorRefProvider"
 
 debug {
  receive = on
  autoreceive = on
  lifecycle = on
  fsm = on
  event-stream = on
  unhandled = on
  router-misconfiguration = on
}
  }
  
  remote 
  {
log-remote-lifecycle-events = off
netty.tcp {
  hostname = "127.0.0.1"
  port = 2551
}
  }
}

 
We have defined our Java code where we are loading config file using  

 
ActorSystem system = ActorSystem.create("ClusterSystem", config); 

 

 
As per current configuration, we are listening to TCP Port. please help to 
figure out how to pass new docker image IP/Port information to all the 
current running docker images.  

 

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