From c13113e92facf2af8b0536972103455a96155a29 Mon Sep 17 00:00:00 2001
From: Blake Niemyjski <bniemyjski@gmail.com>
Date: Thu, 26 Sep 2024 22:41:58 -0500
Subject: [PATCH] Pass in correlation id to queue entry

---
 src/Foundatio.Redis/Queues/RedisQueue.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Foundatio.Redis/Queues/RedisQueue.cs b/src/Foundatio.Redis/Queues/RedisQueue.cs
index 5788067..0be8ce6 100644
--- 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");