diff --git a/src/modules/Elsa.Workflows.Runtime/Models/NewBookmarkQueueItem.cs b/src/modules/Elsa.Workflows.Runtime/Models/NewBookmarkQueueItem.cs
index c1e030ff9..2020604c4 100644
--- a/src/modules/Elsa.Workflows.Runtime/Models/NewBookmarkQueueItem.cs
+++ b/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>
diff --git a/src/modules/Elsa.Workflows.Runtime/Services/StimulusSender.cs b/src/modules/Elsa.Workflows.Runtime/Services/StimulusSender.cs
index 58894281c..bbb688550 100644
--- a/src/modules/Elsa.Workflows.Runtime/Services/StimulusSender.cs
+++ b/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()
                 {
diff --git a/src/modules/Elsa.Workflows.Runtime/Services/StoreBookmarkQueue.cs b/src/modules/Elsa.Workflows.Runtime/Services/StoreBookmarkQueue.cs
index 77b7b5d5b..90bedb833 100644
--- a/src/modules/Elsa.Workflows.Runtime/Services/StoreBookmarkQueue.cs
+++ b/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,