From 459d5e48036d939cad18ed2b5fd2d6cb5f536ec1 Mon Sep 17 00:00:00 2001 From: maliming Date: Thu, 19 Mar 2026 09:34:26 +0800 Subject: [PATCH] fix: skip delayed queue when delay is zero or negative --- .../Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 4dbb705532..ddc2613b47 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 @@ -176,10 +176,10 @@ public class JobQueue : IJobQueue CorrelationId = CorrelationIdProvider.Get() }; - if (delay.HasValue) + if (delay.HasValue && delay.Value > TimeSpan.Zero) { routingKey = QueueConfiguration.DelayedQueueName; - basicProperties.Expiration = Math.Max(0, (long)Math.Ceiling(delay.Value.TotalMilliseconds)).ToString(CultureInfo.InvariantCulture); + basicProperties.Expiration = ((long)Math.Ceiling(delay.Value.TotalMilliseconds)).ToString(CultureInfo.InvariantCulture); } if (ChannelAccessor != null)