Add CorrelationId to RabbitMQ job messages

1 week ago · fcc1315014
1 changed files with 2 additions and 1 deletions
--- 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)