eventstream에서 error를 구독하는 액터 추가

seungyongshim · May 7, 2020 · 50d208f · 50d208f
1 parent 9834697
commit 50d208f
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 3 deletions.
diff --git a/Actors/EventSubscribeActor.cs b/Actors/EventSubscribeActor.cs
@@ -0,0 +1,20 @@
+using Akka.Actor;
+using Akka.Event;
+
+namespace BLUECATS.ToastNotifier.Actors
+{
+    public class EventSubscribeActor : ReceiveActor, IWithUnboundedStash
+    {
+        public IStash Stash { get; set; }
+
+        public static Props Props(IActorRef notificationActor)
+        {
+            return Akka.Actor.Props.Create(() => new EventSubscribeActor(notificationActor));
+        }
+
+        public EventSubscribeActor(IActorRef notificationActor)
+        {
+            Receive<Error>(m => { notificationActor.Tell(m.ToString()); });
+        }
+    }
+}
diff --git a/Actors/NotificationActor.cs b/Actors/NotificationActor.cs
@@ -44,6 +44,8 @@ public NotificationActor(Notifier notifier)
                 
                 BecomeStacked(Delaying);
             });
+
+            Receive<string>(m => notifier.ShowError(m));
         }
 
         private void Delaying()

diff --git a/App.xaml.cs b/App.xaml.cs
@@ -55,8 +55,6 @@ protected override void OnStartup(StartupEventArgs e)
                 var fileVersionInfo = FileVersionInfo.GetVersionInfo(assembly.Location);
                 _version = fileVersionInfo.ProductVersion;
 
-
-
                 var config = AkkaHelper.ReadConfigurationFromHoconFile(Assembly.GetExecutingAssembly(), "conf")
                     .WithFallback(ConfigurationFactory.FromResource<ConsumerSettings<object, object>>("Akka.Streams.Kafka.reference.conf"));
 
@@ -68,7 +66,8 @@ protected override void OnStartup(StartupEventArgs e)
 
                 notificationActor = system.ActorOf(NotificationActor.Props(Notifier), nameof(NotificationActor));
                 var parserActor = system.ActorOf(ParserActor.Props(notificationActor), nameof(ParserActor));
-
+                var eventSubscribeActor = system.ActorOf(EventSubscribeActor.Props(notificationActor), nameof(EventSubscribeActor));
+                system.EventStream.Subscribe(eventSubscribeActor, typeof(Akka.Event.Error));
 
                 var bootStrapServers = GetBootStrapServers(config);
 
@@ -91,6 +90,7 @@ protected override void OnStartup(StartupEventArgs e)
             catch (Exception ex)
             {
                 MessageBox.Show(ex.ToString());
+                Current.Shutdown();
             }
 
             base.OnStartup(e);