Browse Source
Merge pull request #25113 from scrapstation/dev
fix: rabbitmq jobQueue expiration parameter format
pull/25128/head
Ma Liming
2 weeks ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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 = delay.Value.TotalMilliseconds.ToString(CultureInfo.InvariantCulture); |
|
|
|
basicProperties.Expiration = ((long)Math.Ceiling(delay.Value.TotalMilliseconds)).ToString(CultureInfo.InvariantCulture); |
|
|
|
} |
|
|
|
|
|
|
|
if (ChannelAccessor != null) |
|
|
|
|
