Browse Source

Refactor background jobs.

pull/395/head
Halil ibrahim Kalkan 8 years ago
parent
commit
c0f9ff7f74
  1. 1
      framework/src/Volo.Abp.BackgroundJobs.Abstractions/Volo/Abp/BackgroundJobs/BackgroundJobExecuter.cs
  2. 1
      framework/src/Volo.Abp.BackgroundJobs.HangFire/Volo/Abp/BackgroundJobs/Hangfire/HangfireBackgroundJobManager.cs
  3. 2
      framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/BackgroundJobWorker.cs
  4. 7
      framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/DefaultBackgroundJobManager.cs
  5. 0
      framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/IBackgroundJobSerializer.cs
  6. 0
      framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/JsonBackgroundJobSerializer.cs

1
framework/src/Volo.Abp.BackgroundJobs.Abstractions/Volo/Abp/BackgroundJobs/BackgroundJobExecuter.cs

@ -50,7 +50,6 @@ namespace Volo.Abp.BackgroundJobs
Logger.LogException(ex);
//TODO: Somehow trigger an event for the exception (may create an Volo.Abp.ExceptionHandling package)!
throw new BackgroundJobExecutionException("A background job execution is failed. See inner exception for details.", ex)
{
JobType = context.JobType.AssemblyQualifiedName,

1
framework/src/Volo.Abp.BackgroundJobs.HangFire/Volo/Abp/BackgroundJobs/Hangfire/HangfireBackgroundJobManager.cs

@ -5,6 +5,7 @@ using Volo.Abp.DependencyInjection;
namespace Volo.Abp.BackgroundJobs.Hangfire
{
[Dependency(ReplaceServices = true)]
public class HangfireBackgroundJobManager : IBackgroundJobManager, ITransientDependency
{
public Task<string> EnqueueAsync<TArgs>(TArgs args, BackgroundJobPriority priority = BackgroundJobPriority.Normal,

2
framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/BackgroundJobWorker.cs

@ -18,7 +18,7 @@ namespace Volo.Abp.BackgroundJobs
protected IBackgroundJobSerializer Serializer { get; }
/// <summary>
/// Initializes a new instance of the <see cref="BackgroundJobManager"/> class.
/// Initializes a new instance of the <see cref="DefaultBackgroundJobManager"/> class.
/// </summary>
public BackgroundJobWorker(
IBackgroundJobStore store,

7
framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/BackgroundJobManager.cs → framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/DefaultBackgroundJobManager.cs

@ -9,7 +9,8 @@ namespace Volo.Abp.BackgroundJobs
/// <summary>
/// Default implementation of <see cref="IBackgroundJobManager"/>.
/// </summary>
public class BackgroundJobManager : IBackgroundJobManager, ISingletonDependency
[Dependency(TryRegister = true)]
public class DefaultBackgroundJobManager : IBackgroundJobManager, ISingletonDependency
{
protected IClock Clock { get; }
protected IBackgroundJobSerializer Serializer { get; }
@ -17,9 +18,9 @@ namespace Volo.Abp.BackgroundJobs
protected IBackgroundJobStore Store { get; }
/// <summary>
/// Initializes a new instance of the <see cref="BackgroundJobManager"/> class.
/// Initializes a new instance of the <see cref="DefaultBackgroundJobManager"/> class.
/// </summary>
public BackgroundJobManager(
public DefaultBackgroundJobManager(
IClock clock,
IBackgroundJobSerializer serializer,
IBackgroundJobStore store,

0
framework/src/Volo.Abp.BackgroundJobs.Abstractions/Volo/Abp/BackgroundJobs/IBackgroundJobSerializer.cs → framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/IBackgroundJobSerializer.cs

0
framework/src/Volo.Abp.BackgroundJobs.Abstractions/Volo/Abp/BackgroundJobs/JsonBackgroundJobSerializer.cs → framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/JsonBackgroundJobSerializer.cs

Loading…
Cancel
Save