+// Cluster.get(system2).down(AddressFromURIString.parse("akka://cluster-test@127.0.0.1:2558"));
+//
+// shardManager1.underlyingActor().waitForMemberRemoved();
+//
+// shardManager1.tell(new FindPrimary("astronauts", false), getRef());
+//
+// expectMsgClass(duration("5 seconds"), PrimaryNotFoundException.class);