diff --git a/src/modules/Elsa.MassTransit/Consumers/DispatchStimulusRequestConsumer.cs b/src/modules/Elsa.MassTransit/Consumers/DispatchStimulusRequestConsumer.cs
index b8bb52397..49fe0bc9e 100644
--- a/src/modules/Elsa.MassTransit/Consumers/DispatchStimulusRequestConsumer.cs
+++ b/src/modules/Elsa.MassTransit/Consumers/DispatchStimulusRequestConsumer.cs
@@ -16,16 +16,19 @@ public class DispatchStimulusRequestConsumer(IStimulusSender stimulusSender, IPa
         var message = context.Message;
         var json = message.SerializedRequest;
         var request = payloadSerializer.Deserialize<DispatchStimulusRequest>(json);
-        
-        if(request.ActivityTypeName != null)
+
+        if (request.ActivityTypeName != null)
         {
             await stimulusSender.SendAsync(request.ActivityTypeName, request.Stimulus!, request.Metadata, cancellationToken);
             return;
         }
-        
-        if(request.StimulusHash != null)
+
+        if (request.StimulusHash != null)
+        {
             await stimulusSender.SendAsync(request.StimulusHash!, request.Metadata, cancellationToken);
-        
+            return;
+        }
+
         throw new InvalidOperationException("Either ActivityTypeName or StimulusHash must be specified.");
     }
 }
\ No newline at end of file
diff --git a/src/modules/Elsa.Workflows.Runtime/Handlers/DispatchStimulusCommandHandler.cs b/src/modules/Elsa.Workflows.Runtime/Handlers/DispatchStimulusCommandHandler.cs
index 6c3eb66d2..724714596 100644
--- a/src/modules/Elsa.Workflows.Runtime/Handlers/DispatchStimulusCommandHandler.cs
+++ b/src/modules/Elsa.Workflows.Runtime/Handlers/DispatchStimulusCommandHandler.cs
@@ -11,16 +11,19 @@ public class DispatchStimulusCommandHandler(IStimulusSender stimulusSender) : IC
     public async Task<Unit> HandleAsync(DispatchStimulusCommand command, CancellationToken cancellationToken)
     {
         var request = command.Request;
-        
-        if(request.ActivityTypeName != null)
+
+        if (request.ActivityTypeName != null)
         {
             await stimulusSender.SendAsync(request.ActivityTypeName, request.Stimulus!, request.Metadata, cancellationToken);
             return Unit.Instance;
         }
-        
-        if(request.StimulusHash != null)
+
+        if (request.StimulusHash != null)
+        {
             await stimulusSender.SendAsync(request.StimulusHash!, request.Metadata, cancellationToken);
-        
+            return Unit.Instance;
+        }
+
         throw new InvalidOperationException("Either ActivityTypeName or StimulusHash must be specified.");
     }
 }
\ No newline at end of file