From fcc13150143defc3ca1b7681ac349a2584378667 Mon Sep 17 00:00:00 2001
From: maliming <malimings@gmail.com>
Date: Wed, 28 Jan 2026 08:23:51 +0800
Subject: [PATCH] Add CorrelationId to RabbitMQ job messages

---
 .../Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs               | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs b/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs
index 3d55bb67b4..1e2280b78a 100644
--- a/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs
+++ b/framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs
@@ -172,7 +172,8 @@ public class JobQueue<TArgs> : IJobQueue<TArgs>
         var routingKey = QueueConfiguration.QueueName;
         var basicProperties = new BasicProperties
         {
-            Persistent = true
+            Persistent = true,
+            CorrelationId = CorrelationIdProvider.Get()
         };
 
         if (delay.HasValue)