2014-10-28 14 views
10

Próbuję utworzyć prosty test Hangfire, ale nie działa. Oto cały ważny kod i sposób, w jaki skonfigurowałem go z Hangire.Autofac. Nie jestem pewien, czego tu brakuje. Wyjątek, który otrzymuję w dashbaord/hangfire, znajduje się poniżej.Hangfire.Autofac z aplikacją MVC - iniekcja kończy się niepowodzeniem

public class AmazonSqsService : IAmazonSqsService 
{ 
    private readonly IBackgroundJobClient _backgroundJobClient; 
    private readonly ILogService _logService; 

    public AmazonSqsService(IBackgroundJobClient backgroundJobClient, ILogService logService) 
    { 

     _backgroundJobClient. = backgroundJobClient; 
     _logService= logService; 
    } 

    public async Task<string> Test() 
    { 

     return _backgroundJobClient.Enqueue(() => Looper()); 

    } 

    public void Looper() { 
     while (true) { _logService.Info("In Looper Loop"); Thread.Sleep(5000); } 
    } 
} 

public partial class Startup 
{ 
    public static IContainer ConfigureContainer() 
    { 
     var builder = new ContainerBuilder(); 
     RegisterApplicationComponents(builder); 
     AppGlobal.Container = builder.Build(); 
    } 

    public static void RegisterApplicationComponents(ContainerBuilder builder) 
    { 
     builder.RegisterType<LogService>().As<ILogService>().InstancePerLifetimeScope(); 
     builder.RegisterType<AmazonSqsService>().As<IAmazonSqsService>().InstancePerLifetimeScope(); 
     builder.RegisterType<BackgroundJobClient>().As<IBackgroundJobClient>().InstancePerLifetimeScope(); 
     builder.Register(c => JobStorage.Current).As<JobStorage>().InstancePerLifetimeScope(); 
     builder.Register(c => new StateMachineFactory(JobStorage.Current)).As<IStateMachineFactory>().InstancePerLifetimeScope(); 

    } 

    public static void ConfigureHangfire(IAppBuilder app) 
    { 
     app.UseHangfire(config => 
     { 
      config.UseAutofacActivator(AppGlobal.Container); 
      config.UseSqlServerStorage("DefaultDatabase"); 
      config.UseServer(); 
     }); 
    } 
} 

Jednak w desce rozdzielczej Wciąż otrzymuję ten błąd dla zadania:

Failed Wystąpił wyjątek podczas aktywizacji zawodowej. Autofac.Core.Registration.ComponentNotRegisteredException

Żądana usługa "App.Services.AmazonSqsService" nie została zarejestrowana. Aby uniknąć tego wyjątku, należy zarejestrować komponent w celu świadczenia usługi, sprawdzić rejestrację usługi za pomocą funkcji IsRegistered() lub użyć metody ResolveOptional() w celu rozwiązania opcjonalnej zależności.

Odpowiedz

21

W końcu to wymyśliłem.

Użytkowanie:

public class Service : IService { 
     public void MethodToQueue() { ... } 
} 

public class AnyOtherClass { 
    public void StartTasks() { 
      BackgroundJob.Enqueue<IService>(x => x.MethodToQueue()); //Good 
    } 
} 

Niewłaściwe użytkowanie (co robiłem źle)

public class Service : IService { 
    public void StartTasks() { 
      BackgroundJob.Enqueue(() => this.MethodToQueue()); //Bad 
    } 

     public void MethodToQueue() { ... } 
} 

public class AnyOtherClass { 
    public AnyOtherClass(IService service) { 
      service.StartTasks(); 
    } 
} 
+0

robiłem ten sam błąd .. Dziękuję .. !! – Praveen