updated Akka.Cluster samples (#4725)

akkadotnet · Jan 19, 2021 · ba6619a · ba6619a
1 parent 7f045af
commit ba6619a
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/src/examples/Cluster/Roles/Samples.Cluster.Transformation/App.config b/src/examples/Cluster/Roles/Samples.Cluster.Transformation/App.config
@@ -11,7 +11,7 @@
       <![CDATA[
           akka {
             actor {
-              provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
+              provider = cluster
             }
             
             remote {

diff --git a/src/examples/Cluster/Roles/Samples.Cluster.Transformation/Program.cs b/src/examples/Cluster/Roles/Samples.Cluster.Transformation/Program.cs
@@ -29,7 +29,7 @@ static void Main(string[] args)
             LaunchFrontend(new string[0]);
             //starting 2 frontend nodes and 3 backend nodes
             Console.WriteLine("Press any key to exit.");
-            Console.ReadKey();
+            Console.ReadLine();
         }
 
         static void LaunchBackend(string[] args)

diff --git a/src/examples/Cluster/Samples.Cluster.Simple/App.config b/src/examples/Cluster/Samples.Cluster.Simple/App.config
@@ -11,7 +11,7 @@
       <![CDATA[
           akka {
             actor {
-              provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
+              provider = cluster
             }
             
             remote {

diff --git a/src/examples/Cluster/Samples.Cluster.Simple/SimpleClusterListener.cs b/src/examples/Cluster/Samples.Cluster.Simple/SimpleClusterListener.cs
@@ -42,6 +42,9 @@ protected override void OnReceive(object message)
                     Log.Info("Member is Up: {0}", mem.Member);
                     break;
                 }
+                case ClusterEvent.MemberJoined joined:
+                    Log.Info("Member is joining {0}", joined.Member);
+                    break;
                 case ClusterEvent.UnreachableMember unreachable:
                     Log.Info("Member detected as unreachable: {0}", unreachable.Member);
                     break;