Added different exception types

Author: irinascurtu

src/Billing/SimulationEffects.cs

@@ -1,5 +1,6 @@
 namespace Billing;
 
+using Helper;
 using MassTransit;
 using Messages;
 using Microsoft.AspNetCore.SignalR;
@@ -29,7 +30,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/Helper/BillingProcessingException.cs

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

src/Helper/OrderBilledException.cs

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

src/Helper/OrderPlacedException.cs

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

src/Helper/SalesProcessingException.cs

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

src/Sales/SimulationEffects.cs

@@ -1,5 +1,6 @@
 namespace Sales;
 
+using Helper;
 using MassTransit;
 using Messages;
 using Microsoft.AspNetCore.SignalR;
@@ -29,7 +30,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/SimulationEffects.cs

@@ -1,5 +1,6 @@
 namespace Shipping;
 
+using Helper;
 using MassTransit;
 using Messages;
 using Microsoft.AspNetCore.SignalR;
@@ -33,7 +34,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 +60,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);