Browse Source
fix: skip delayed queue when delay is zero or negative
pull/25113/head
maliming
2 months ago
No known key found for this signature in database
GPG Key ID: A646B9CB645ECEA4
1 changed files with
2 additions and
2 deletions
-
framework/src/Volo.Abp.BackgroundJobs.RabbitMQ/Volo/Abp/BackgroundJobs/RabbitMQ/JobQueue.cs
|
|
|
@ -176,10 +176,10 @@ public class JobQueue<TArgs> : IJobQueue<TArgs> |
|
|
|
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) |
|
|
|
|
