|
|
@ -23,7 +23,7 @@ namespace Volo.Abp.BackgroundJobs.RabbitMQ |
|
|
protected JobQueueConfiguration QueueConfiguration { get; } |
|
|
protected JobQueueConfiguration QueueConfiguration { get; } |
|
|
protected IChannelAccessor ChannelAccessor { get; private set; } |
|
|
protected IChannelAccessor ChannelAccessor { get; private set; } |
|
|
protected EventingBasicConsumer Consumer { get; private set; } |
|
|
protected EventingBasicConsumer Consumer { get; private set; } |
|
|
|
|
|
|
|
|
public ILogger<JobQueue<TArgs>> Logger { get; set; } |
|
|
public ILogger<JobQueue<TArgs>> Logger { get; set; } |
|
|
|
|
|
|
|
|
protected AbpBackgroundJobOptions AbpBackgroundJobOptions { get; } |
|
|
protected AbpBackgroundJobOptions AbpBackgroundJobOptions { get; } |
|
|
@ -76,7 +76,7 @@ namespace Volo.Abp.BackgroundJobs.RabbitMQ |
|
|
{ |
|
|
{ |
|
|
CheckDisposed(); |
|
|
CheckDisposed(); |
|
|
|
|
|
|
|
|
using (await SyncObj.LockAsync()) |
|
|
using (await SyncObj.LockAsync().ConfigureAwait(false)) |
|
|
{ |
|
|
{ |
|
|
await EnsureInitializedAsync(); |
|
|
await EnsureInitializedAsync(); |
|
|
|
|
|
|
|
|
@ -95,7 +95,7 @@ namespace Volo.Abp.BackgroundJobs.RabbitMQ |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
using (await SyncObj.LockAsync()) |
|
|
using (await SyncObj.LockAsync().ConfigureAwait(false)) |
|
|
{ |
|
|
{ |
|
|
await EnsureInitializedAsync(); |
|
|
await EnsureInitializedAsync(); |
|
|
} |
|
|
} |
|
|
@ -151,7 +151,7 @@ namespace Volo.Abp.BackgroundJobs.RabbitMQ |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
protected virtual Task PublishAsync( |
|
|
protected virtual Task PublishAsync( |
|
|
TArgs args, |
|
|
TArgs args, |
|
|
BackgroundJobPriority priority = BackgroundJobPriority.Normal, |
|
|
BackgroundJobPriority priority = BackgroundJobPriority.Normal, |
|
|
TimeSpan? delay = null) |
|
|
TimeSpan? delay = null) |
|
|
{ |
|
|
{ |
|
|
|