Remove Message base constraint

justeattakeaway · Apr 11, 2023 · 4fa7a3e · 4fa7a3e
1 parent 5f3628e
commit 4fa7a3e
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/src/JustSaying/AwsTools/MessageHandling/Dispatch/MessageDispatcher.cs b/src/JustSaying/AwsTools/MessageHandling/Dispatch/MessageDispatcher.cs
@@ -36,29 +36,29 @@ public class MessageDispatcher : IMessageDispatcher
             return;
         }
 
-        (bool success, object typedMessage, MessageAttributes attributes) =
+        (bool success, object messageInstance, MessageAttributes attributes) =
             await DeserializeMessage(messageContext, cancellationToken).ConfigureAwait(false);
 
         if (!success)
         {
             return;
         }
 
-        var messageType = typedMessage.GetType();
+        var messageType = messageInstance.GetType();
         var middleware = _middlewareMap.Get(messageContext.QueueName, messageType);
 
         if (middleware == null)
         {
             _logger.LogError(
                 "Failed to dispatch. Middleware for message of type '{MessageTypeName}' not found in middleware map.",
-                typedMessage.GetType().FullName);
+                messageInstance.GetType().FullName);
             return;
         }
 
         var handleContext = new HandleMessageContext(
             messageContext.QueueName,
             messageContext.Message,
-            typedMessage,
+            messageInstance,
             messageType,
             messageContext,
             messageContext,
@@ -70,9 +70,7 @@ await middleware.RunAsync(handleContext, null, cancellationToken)
 
     }
 
-    // TODO rename typedMessage to messageInstance
-    private async Task<(bool success, object typedMessage, MessageAttributes attributes)>
-        DeserializeMessage(IQueueMessageContext messageContext, CancellationToken cancellationToken)
+    private async Task<(bool success, object messageInstance, MessageAttributes attributes)> DeserializeMessage(IQueueMessageContext messageContext, CancellationToken cancellationToken)
     {
         try
         {