Class JobQueueManager

Inheritance
object
JobQueueManager
Implements
Inherited Members
object.GetType()
object.MemberwiseClone()
object.ToString()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Namespace: Volo.Abp.BackgroundJobs.RabbitMQ
Assembly: Volo.Abp.BackgroundJobs.RabbitMQ.dll
Syntax
public class JobQueueManager : IJobQueueManager, IRunnable, ISingletonDependency

Constructors

JobQueueManager(IOptions<AbpBackgroundJobOptions>, IServiceProvider)

Declaration
public JobQueueManager(IOptions<AbpBackgroundJobOptions> options, IServiceProvider serviceProvider)
Parameters
Type Name Description
Microsoft.Extensions.Options.IOptions<TOptions><AbpBackgroundJobOptions> options
System.IServiceProvider serviceProvider

Properties

JobQueues

Declaration
protected ConcurrentDictionary<string, IRunnable> JobQueues { get; }
Property Value
Type Description
System.Collections.Concurrent.ConcurrentDictionary<TKey, TValue><string, IRunnable>

Options

Declaration
protected AbpBackgroundJobOptions Options { get; }
Property Value
Type Description
AbpBackgroundJobOptions

ServiceProvider

Declaration
protected IServiceProvider ServiceProvider { get; }
Property Value
Type Description
System.IServiceProvider

SyncSemaphore

Declaration
protected SemaphoreSlim SyncSemaphore { get; }
Property Value
Type Description
System.Threading.SemaphoreSlim

Methods

GetAsync<TArgs>()

Declaration
public Task<IJobQueue<TArgs>> GetAsync<TArgs>()
Returns
Type Description
System.Threading.Tasks.Task<TResult><IJobQueue<TArgs>>
Type Parameters
Name Description
TArgs

StartAsync(CancellationToken)

Declaration
public Task StartAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
System.Threading.CancellationToken cancellationToken
Returns
Type Description
System.Threading.Tasks.Task

StopAsync(CancellationToken)

Declaration
public Task StopAsync(CancellationToken cancellationToken = default)
Parameters
Type Name Description
System.Threading.CancellationToken cancellationToken
Returns
Type Description
System.Threading.Tasks.Task

Implements

Extension Methods