From 817066b097cc2e4ee30ea2601c89c2f36b5dc8b2 Mon Sep 17 00:00:00 2001
From: maliming <malimings@gmail.com>
Date: Thu, 19 Mar 2026 09:23:28 +0800
Subject: [PATCH] fix: use ceiling rounding for RabbitMQ message expiration TTL

---
 .../Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs                | 2 +-
 1 file changed, 1 insertion(+), 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 25b840d073..7f302efded 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
@@ -179,7 +179,7 @@ public class JobQueue<TArgs> : IJobQueue<TArgs>
         if (delay.HasValue)
         {
             routingKey = QueueConfiguration.DelayedQueueName;
-            basicProperties.Expiration = ((long)delay.Value.TotalMilliseconds).ToString(CultureInfo.InvariantCulture);
+            basicProperties.Expiration = Math.Max(1, (long)Math.Ceiling(delay.Value.TotalMilliseconds)).ToString(CultureInfo.InvariantCulture);
         }
 
         if (ChannelAccessor != null)