Show / Hide Table of Contents

Class JobQueueManager

Inheritance
System.Object
JobQueueManager
Implements
IJobQueueManager
IRunnable
ISingletonDependency
Namespace: Volo.Abp.BackgroundJobs.RabbitMQ
Assembly: Volo.Abp.BackgroundJobs.RabbitMQ.dll
Syntax
public class JobQueueManager : object, IJobQueueManager, IRunnable, ISingletonDependency

Constructors

JobQueueManager(IOptions<AbpBackgroundJobOptions>, IServiceProvider)

Declaration
public JobQueueManager(IOptions<AbpBackgroundJobOptions> options, IServiceProvider serviceProvider)
Parameters
Type Name Description
IOptions<AbpBackgroundJobOptions> options
IServiceProvider serviceProvider

Properties

JobQueues

Declaration
protected ConcurrentDictionary<string, IRunnable> JobQueues { get; }
Property Value
Type Description
ConcurrentDictionary<System.String, IRunnable>

Options

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

ServiceProvider

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

SyncSemaphore

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

Methods

GetAsync<TArgs>()

Declaration
public Task<IJobQueue<TArgs>> GetAsync<TArgs>()
Returns
Type Description
Task<IJobQueue<TArgs>>
Type Parameters
Name Description
TArgs

StartAsync(CancellationToken)

Declaration
public Task StartAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task

StopAsync(CancellationToken)

Declaration
public Task StopAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task

Implements

IJobQueueManager
IRunnable
ISingletonDependency

Extension Methods

AbpObjectExtensions.As<T>(Object)
AbpObjectExtensions.To<T>(Object)
AbpObjectExtensions.IsIn<T>(T, T[])
AbpObjectExtensions.If<T>(T, Boolean, Func<T, T>)
AbpObjectExtensions.If<T>(T, Boolean, Action<T>)
LockExtensions.Locking(Object, Action)
LockExtensions.Locking<T>(T, Action<T>)
LockExtensions.Locking<TResult>(Object, Func<TResult>)
LockExtensions.Locking<T, TResult>(T, Func<T, TResult>)
Back to top Powered by Volosoft