Add CorrelationId to RabbitMQ job messages

maliming · maliming · commit fcc13150143d · 2026-01-28T08:23:51.000+08:00
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
@@ -172,7 +172,8 @@ protected virtual async Task PublishAsync(
         var routingKey = QueueConfiguration.QueueName;
         var basicProperties = new BasicProperties
         {
-            Persistent = true
+            Persistent = true,
+            CorrelationId = CorrelationIdProvider.Get()
         };
 
         if (delay.HasValue)

Original file line number	Diff line number	Diff line change
`@@ -172,7 +172,8 @@ protected virtual async Task PublishAsync(`
`172`	`172`	`var routingKey = QueueConfiguration.QueueName;`
`173`	`173`	`var basicProperties = new BasicProperties`
`174`	`174`	`{`
`175`		`- Persistent = true`
	`175`	`+ Persistent = true,`
	`176`	`+ CorrelationId = CorrelationIdProvider.Get()`
`176`	`177`	`};`
`177`	`178`
`178`	`179`	`if (delay.HasValue)`