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");