Merge pull request #85 from Particular/exceptions

Added different exception types

Author: irinascurtu

src/Billing/BillingProcessingException.cs

@@ -0,0 +1,11 @@
+namespace Billing
+{
+    using System;
+
+    public class BillingProcessingException : Exception
+    {
+        public BillingProcessingException(string message) : base(message)
+        {
+        }
+    }
+}

src/Billing/SimulationEffects.cs

@@ -1,5 +1,4 @@
 namespace Billing;
-
 using MassTransit;
 using Messages;
 using Microsoft.AspNetCore.SignalR;
@@ -29,7 +28,7 @@ public async Task SimulateBillingProcessing(ConsumeContext<OrderPlaced> context)
                     && (!isRetry || ShouldFailRetries))
             {
                 Interlocked.Increment(ref messagesErrored);
-                throw new Exception($"A simulated failure occurred in Billing, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
+                throw new BillingProcessingException($"A simulated failure occurred in Billing, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
             }
 
             Interlocked.Increment(ref messagesProcessed);

src/Sales/SalesProcessingException.cs

@@ -0,0 +1,10 @@
+namespace Sales
+{
+
+    public class SalesProcessingException : Exception
+    {
+        public SalesProcessingException(string message) : base(message)
+        {
+        }
+    }
+}

src/Sales/SimulationEffects.cs

@@ -1,5 +1,4 @@
 namespace Sales;
-
 using MassTransit;
 using Messages;
 using Microsoft.AspNetCore.SignalR;
@@ -29,7 +28,7 @@ public async Task SimulateSalesProcessing(ConsumeContext<PlaceOrder> context)
                     && (!isRetry || ShouldFailRetries))
             {
                 Interlocked.Increment(ref messagesErrored);
-                throw new Exception($"A simulated failure occurred in Sales, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
+                throw new SalesProcessingException($"A simulated failure occurred in Sales, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
             }
 
             Interlocked.Increment(ref messagesProcessed);

src/Shipping/OrderBilledException.cs

@@ -0,0 +1,9 @@
+namespace Shipping
+{
+    public class OrderBilledException : Exception
+    {
+        public OrderBilledException(string message) : base(message)
+        {
+        }
+    }
+}

src/Shipping/OrderPlacedException.cs

@@ -0,0 +1,9 @@
+namespace Shipping
+{
+    public class OrderPlacedException : Exception
+    {
+        public OrderPlacedException(string message) : base(message)
+        {
+        }
+    }
+}

src/Shipping/SimulationEffects.cs

@@ -1,5 +1,4 @@
 namespace Shipping;
-
 using MassTransit;
 using Messages;
 using Microsoft.AspNetCore.SignalR;
@@ -33,7 +32,7 @@ public async Task SimulateOrderBilledProcessing(ConsumeContext<OrderBilled> cont
                     && (!isRetry || ShouldFailRetries))
             {
                 Interlocked.Increment(ref orderBilledErrored);
-                throw new Exception($"A simulated failure occurred in Shipping Order Billed handling, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
+                throw new OrderBilledException($"A simulated failure occurred in Shipping Order Billed handling, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
             }
 
             Interlocked.Increment(ref orderBilledProcessed);
@@ -59,7 +58,7 @@ public async Task SimulateOrderPlacedProcessing(ConsumeContext<OrderPlaced> cont
                     && (!isRetry || ShouldFailRetries))
             {
                 Interlocked.Increment(ref orderPlacedErrored);
-                throw new Exception($"A simulated failure occurred in Shipping Order Placed handling, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
+                throw new OrderPlacedException($"A simulated failure occurred in Shipping Order Placed handling, OrderId: {context.Message.OrderId}, Contents: {string.Join(", ", context.Message.Contents)}");
             }
 
             Interlocked.Increment(ref orderPlacedProcessed);