More cancellation token propagation

Author: ramonsmits

src/ServiceControl/CustomChecks/DeleteCustomCheckHandler.cs

@@ -17,7 +17,7 @@ public async Task Handle(DeleteCustomCheck message, IMessageHandlerContext conte
         {
             await customChecksDataStore.DeleteCustomCheck(message.Id);
 
-            await domainEvents.Raise(new CustomCheckDeleted { Id = message.Id });
+            await domainEvents.Raise(new CustomCheckDeleted { Id = message.Id }, context.CancellationToken);
         }
 
         ICustomChecksDataStore customChecksDataStore;

src/ServiceControl/MessageFailures/Handlers/ArchiveMessageHandler.cs

@@ -26,7 +26,7 @@ public async Task Handle(ArchiveMessage message, IMessageHandlerContext context)
                 await domainEvents.Raise(new FailedMessageArchived
                 {
                     FailedMessageId = failedMessageId
-                });
+                }, context.CancellationToken);
 
                 await dataStore.FailedMessageMarkAsArchived(failedMessageId);
             }

src/ServiceControl/MessageFailures/Handlers/LegacyMessageFailureResolvedHandler.cs

@@ -27,7 +27,7 @@ await domainEvents.Raise(new MessageFailureResolvedByRetry
             {
                 AlternativeFailedMessageIds = message.AlternativeFailedMessageIds,
                 FailedMessageId = message.FailedMessageId
-            });
+            }, context.CancellationToken);
         }
 
         // This is only needed because we might get this from legacy not yet converted instances
@@ -38,7 +38,7 @@ await domainEvents.Raise(new MessageFailureResolvedByRetry
             {
                 AlternativeFailedMessageIds = message.AlternativeFailedMessageIds,
                 FailedMessageId = message.FailedMessageId
-            });
+            }, context.CancellationToken);
         }
 
         async Task MarkAsResolvedByRetry(string primaryId, string[] messageAlternativeFailedMessageIds)

src/ServiceControl/MessageFailures/Handlers/MessageFailureResolvedHandler.cs

@@ -44,7 +44,7 @@ public async Task Handle(MarkPendingRetryAsResolved message, IMessageHandlerCont
             await domainEvents.Raise(new MessageFailureResolvedManually
             {
                 FailedMessageId = message.FailedMessageId
-            });
+            }, context.CancellationToken);
         }
 
         IErrorMessageDataStore dataStore;

src/ServiceControl/MessageFailures/Handlers/UnArchiveMessagesByRangeHandler.cs

@@ -23,7 +23,7 @@ await domainEvents.Raise(new FailedMessagesUnArchived
             {
                 DocumentIds = ids,
                 MessagesCount = ids.Length
-            });
+            }, context.CancellationToken);
 
         }
 

src/ServiceControl/MessageFailures/Handlers/UnArchiveMessagesHandler.cs

@@ -18,7 +18,7 @@ await domainEvents.Raise(new FailedMessagesUnArchived
             {
                 DocumentIds = ids,
                 MessagesCount = ids.Length
-            });
+            }, context.CancellationToken);
         }
     }
 }