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