Add custom job exception

Author: ethanhann

IntegrationEngine.ConsoleHost/IntegrationJobs/SampleSqlReport/SampleSqlReportJob.cs

@@ -11,24 +11,31 @@ public class SampleSqlReportJob : SqlJob
     {
         public override void Run()
         {
-            var report = new SampleReport() {
-                Created = DateTime.Now,
-                Data = new System.Collections.Generic.List<SampleDatum>(),
-                //Data = RunQuery<SampleDatum>(),
-            };
+            try
+            {
+                var report = new SampleReport() {
+                    Created = DateTime.Now,
+                    Data = new System.Collections.Generic.List<SampleDatum>(),
+                    //Data = RunQuery<SampleDatum>(),
+                };
 
-            // 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);
+                // 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);
 
-            // Send Mail
-            var mailMessage = new MailMessage();
-            mailMessage.To.Add("ethanhann@gmail.com");
-            mailMessage.Subject = "Sample SQL Report";
-            mailMessage.From = new MailAddress("root@localhost");
-            mailMessage.Body = html;
-            mailMessage.IsBodyHtml = true;
-            MailClient.Send(mailMessage);
+                // Send Mail
+                var mailMessage = new MailMessage();
+                mailMessage.To.Add("ethanhann@gmail.com");
+                mailMessage.Subject = "Sample SQL Report";
+                mailMessage.From = new MailAddress("root@localhost");
+                mailMessage.Body = html;
+                mailMessage.IsBodyHtml = true;
+                MailClient.Send(mailMessage);
+            }
+            catch (Exception exception)
+            {
+                throw new IntegrationJobRunFailureException("SampleSqlReportJob failed.", exception);
+            }
         }
     }
 }

IntegrationEngine.Core/Jobs/IntegrationJobRunFailureException.cs

@@ -0,0 +1,23 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Runtime.Serialization;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace IntegrationEngine.Core.Jobs
+{
+    public class IntegrationJobRunFailureException : Exception
+    {
+        public IntegrationJobRunFailureException()
+        {}
+
+        public IntegrationJobRunFailureException(string message) 
+            : base(message)
+        {}
+
+        public IntegrationJobRunFailureException(string message, Exception innerException)
+            : base(message, innerException)
+        {}
+    }
+}