Merge pull request #6412 from pkaaz/bug/6409-correlationId-for-bookmark-queue

Add CorrelationId to NewBookmarkQueueItem

src/modules/Elsa.Workflows.Runtime/Models/NewBookmarkQueueItem.cs

@@ -24,6 +24,11 @@ public class NewBookmarkQueueItem
     /// </summary>
     public string? ActivityInstanceId { get; set; }
 
+    /// <summary>
+    /// The correlation ID that is associated with the bookmark if any.
+    /// </summary>
+    public string? CorrelationId { get; set; }
+
     /// <summary>
     /// The type name of the activity associated with the bookmark.
     /// </summary>

src/modules/Elsa.Workflows.Runtime/Services/StimulusSender.cs

@@ -127,6 +127,7 @@ public class StimulusSender(
             {
                 WorkflowInstanceId = workflowInstanceId,
                 BookmarkId = metadata?.BookmarkId,
+                CorrelationId = metadata?.CorrelationId,
                 StimulusHash = stimulusHash,
                 Options = new()
                 {

src/modules/Elsa.Workflows.Runtime/Services/StoreBookmarkQueue.cs

@@ -18,6 +18,7 @@ public class StoreBookmarkQueue(
         var filter = new BookmarkFilter
         {
             BookmarkId = item.BookmarkId,
+            CorrelationId = item.CorrelationId,
             Hash = item.StimulusHash,
             WorkflowInstanceId = item.WorkflowInstanceId,
             ActivityTypeName = item.ActivityTypeName
@@ -39,6 +40,7 @@ public class StoreBookmarkQueue(
             Id = identityGenerator.GenerateId(),
             WorkflowInstanceId = item.WorkflowInstanceId,
             BookmarkId = item.BookmarkId,
+            CorrelationId = item.CorrelationId,
             StimulusHash = item.StimulusHash,
             ActivityInstanceId = item.ActivityInstanceId,
             ActivityTypeName = item.ActivityTypeName,