Pass in correlation id to queue entry

FoundatioFx · Sep 27, 2024 · c13113e · c13113e
1 parent 4bc9c80
commit c13113e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Foundatio.Redis/Queues/RedisQueue.cs b/src/Foundatio.Redis/Queues/RedisQueue.cs
@@ -252,7 +252,7 @@ await Run.WithRetriesAsync(() => Task.WhenAll(
         }
 
         Interlocked.Increment(ref _enqueuedCount);
-        var entry = new QueueEntry<T>(id, null, data, this, now, 0);
+        var entry = new QueueEntry<T>(id, options.CorrelationId, data, this, now, 0);
         await OnEnqueuedAsync(entry).AnyContext();
 
         if (isTraceLogLevelEnabled) _logger.LogTrace("Enqueue done");