fix: rabbitmq jobQueue expiration parameter format

2 weeks ago · bbebdf5bac
1 changed files with 1 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
@ -179,7 +179,7 @@ public class JobQueue<TArgs> : IJobQueue<TArgs>
        if (delay.HasValue)
        {
            routingKey = QueueConfiguration.DelayedQueueName;
-            basicProperties.Expiration = delay.Value.TotalMilliseconds.ToString(CultureInfo.InvariantCulture);
+            basicProperties.Expiration = ((long)delay.Value.TotalMilliseconds).ToString(CultureInfo.InvariantCulture);
        }

        if (ChannelAccessor != null)