Browse Source
Simplify AbpTickerQFunctionProvider and add input validation to AddFunction
pull/25091/head
maliming
2 weeks ago
No known key found for this signature in database
GPG Key ID: A646B9CB645ECEA4
1 changed files with
12 additions and
1 deletions
-
framework/src/Volo.Abp.TickerQ/Volo/Abp/TickerQ/AbpTickerQFunctionProvider.cs
|
|
@ -24,6 +24,17 @@ public class AbpTickerQFunctionProvider : ISingletonDependency |
|
|
TickerTaskPriority priority = TickerTaskPriority.Normal, |
|
|
TickerTaskPriority priority = TickerTaskPriority.Normal, |
|
|
int maxConcurrency = 0) |
|
|
int maxConcurrency = 0) |
|
|
{ |
|
|
{ |
|
|
Functions.TryAdd(name, (string.Empty, priority, function, maxConcurrency)); |
|
|
Check.NotNullOrWhiteSpace(name, nameof(name)); |
|
|
|
|
|
Check.NotNull(function, nameof(function)); |
|
|
|
|
|
|
|
|
|
|
|
if (maxConcurrency < 0) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new ArgumentException("maxConcurrency must be greater than or equal to 0.", nameof(maxConcurrency)); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (!Functions.TryAdd(name, (string.Empty, priority, function, maxConcurrency))) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new AbpException($"A function with the name '{name}' is already registered."); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|