Add OverrideReceiver to AkkaReceiverNotificationChannel.

SaladLab · Jul 13, 2016 · eb33d26 · eb33d26
1 parent 453a82c
commit eb33d26
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/core/Akka.Interfaced/AkkaReceiverNotificationChannel.cs b/core/Akka.Interfaced/AkkaReceiverNotificationChannel.cs
@@ -4,7 +4,7 @@ namespace Akka.Interfaced
 {
     public class AkkaReceiverNotificationChannel : INotificationChannel
     {
-        public ICanTell Receiver { get; }
+        public ICanTell Receiver { get; private set; }
 
         private int _lastNotificationId;
 
@@ -38,5 +38,19 @@ public override int GetHashCode()
         {
             return Receiver.GetHashCode();
         }
+
+        public static bool OverrideReceiver(INotificationChannel channel, ICanTell receiver)
+        {
+            var akkaChannel = channel as AkkaReceiverNotificationChannel;
+            if (akkaChannel != null)
+            {
+                akkaChannel.Receiver = receiver;
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
     }
 }