EventTriggerAsyncBackgroundJob.cs 548 B

12345678910111213141516171819202122
  1. using System.Threading.Tasks;
  2. using Abp.Dependency;
  3. using Abp.Events.Bus;
  4. namespace Abp.BackgroundJobs
  5. {
  6. public class EventTriggerAsyncBackgroundJob<TEvent> : AsyncBackgroundJob<TEvent>, ITransientDependency
  7. where TEvent : EventData
  8. {
  9. public IEventBus EventBus { get; set; }
  10. public EventTriggerAsyncBackgroundJob()
  11. {
  12. EventBus = NullEventBus.Instance;
  13. }
  14. protected override async Task ExecuteAsync(TEvent e)
  15. {
  16. await EventBus.TriggerAsync(e);
  17. }
  18. }
  19. }