Use SchedulerListener to delete a SimpleTrigger from ES after it finishes

Author: ethanhann

IntegrationEngine.ConsoleHost/IntegrationJobs/SampleSqlReport/SampleSqlReportJob.cs

@@ -17,8 +17,6 @@ public override void Run()
                 //Data = RunQuery<SampleDatum>(),
             };
 
-            // Write result to Elasticsearch
-
             // Pass into Razor engine
             string template = "Created on <strong>@Model.Created</strong> with <strong>@Model.Data.Count</strong> records.";
             var html = Engine.Razor.RunCompile(template, "template-01", typeof(SampleReport), report);

IntegrationEngine/EngineHostConfiguration.cs

@@ -132,6 +132,11 @@ public void SetupEngineScheduler(ILog log, IMessageQueueClient messageQueueClien
                 Log = log,
             };
             Container.RegisterInstance<IEngineScheduler>(engineScheduler);
+            var engineSchedulerListener = new EngineSchedulerListener() {
+                ElasticsearchRepository = elasticsearchRepository,
+                Log = log,
+            };
+            engineScheduler.AddSchedulerListener(engineSchedulerListener);
             engineScheduler.Start();
             var simpleTriggers = elasticsearchRepository.SelectAll<SimpleTrigger>();
             var allCronTriggers = elasticsearchRepository.SelectAll<CronTrigger>();

IntegrationEngine/IntegrationEngine.csproj

@@ -156,8 +156,9 @@
     <Compile Include="MessageQueue\MsmqClient.cs" />
     <Compile Include="MessageQueue\MsmqListener.cs" />
     <Compile Include="Scheduler\CronTrigger.cs" />
+    <Compile Include="Scheduler\IEngineSchedulerListener.cs" />
+    <Compile Include="Scheduler\EngineSchedulerListener.cs" />
     <Compile Include="Scheduler\SimpleTrigger.cs" />
-    <Compile Include="Scheduler\TriggerListener.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="MessageQueue\IMessageQueueClient.cs" />
     <Compile Include="MessageQueue\RabbitMQClient.cs" />

IntegrationEngine/Scheduler/EngineScheduler.cs

@@ -23,12 +23,14 @@ public EngineScheduler()
 
         public void Start()
         {
-            var triggerListener = new TriggerListener();
-            var mgr = Scheduler.ListenerManager;
-            mgr.AddTriggerListener(triggerListener, GroupMatcher<TriggerKey>.AnyGroup());
             Scheduler.Start();
         }
 
+        public void AddSchedulerListener(EngineSchedulerListener engineSchedulerListener)
+        {
+            Scheduler.ListenerManager.AddSchedulerListener(engineSchedulerListener);
+        }
+
         public virtual void Shutdown()
         {
             Scheduler.Shutdown();

IntegrationEngine/Scheduler/EngineSchedulerListener.cs

@@ -0,0 +1,102 @@
+using Common.Logging;
+using IntegrationEngine.Core.Storage;
+using Quartz;
+using System;
+
+namespace IntegrationEngine.Scheduler
+{
+    public class EngineSchedulerListener : IEngineSchedulerListener
+    {
+        public IElasticsearchRepository ElasticsearchRepository { get; set; }
+        public ILog Log { get; set; }
+
+        public void JobAdded(IJobDetail jobDetail)
+        {
+        }
+
+        public void JobDeleted(JobKey jobKey)
+        {
+        }
+
+        public void JobPaused(JobKey jobKey)
+        {
+        }
+
+        public void JobResumed(JobKey jobKey)
+        {
+        }
+
+        public void JobScheduled(ITrigger trigger)
+        {
+        }
+
+        public void JobUnscheduled(TriggerKey triggerKey)
+        {
+        }
+
+        public void JobsPaused(string jobGroup)
+        {
+        }
+
+        public void JobsResumed(string jobGroup)
+        {
+        }
+
+        public void SchedulerError(string msg, SchedulerException cause)
+        {
+        }
+
+        public void SchedulerInStandbyMode()
+        {
+        }
+
+        public void SchedulerShutdown()
+        {
+        }
+
+        public void SchedulerShuttingdown()
+        {
+        }
+
+        public void SchedulerStarted()
+        {
+        }
+
+        public void SchedulerStarting()
+        {
+        }
+
+        public void SchedulingDataCleared()
+        {
+        }
+
+        public void TriggerFinalized(ITrigger trigger)
+        {
+            try
+            {
+                if (trigger is ISimpleTrigger)
+                    ElasticsearchRepository.Delete<SimpleTrigger>(trigger.Key.Name);       
+            }
+            catch (Exception exception)
+            {
+                Log.Error("Error deleting simple trigger.", exception);
+            }
+        }
+
+        public void TriggerPaused(TriggerKey triggerKey)
+        {
+        }
+
+        public void TriggerResumed(TriggerKey triggerKey)
+        {
+        }
+
+        public void TriggersPaused(string triggerGroup)
+        {
+        }
+
+        public void TriggersResumed(string triggerGroup)
+        {
+        }
+    }
+}

IntegrationEngine/Scheduler/IEngineSchedulerListener.cs

@@ -0,0 +1,12 @@
+using Common.Logging;
+using IntegrationEngine.Core.Storage;
+using Quartz;
+
+namespace IntegrationEngine.Scheduler
+{
+    public interface IEngineSchedulerListener : ISchedulerListener
+    {
+        IElasticsearchRepository ElasticsearchRepository { get; set; }
+        ILog Log { get; set; }
+    }
+}