Appel Masstransit IRequestClient.Request à partir du blocage de travail Quartz

Question

J'ai un rapport qui appelle le service métier via l'appel de méthode Masstransit IRequestClient.Request.

Si ce rapport est généré à partir de l'interface utilisateur (contrôleur ASP.NET MVC), tout fonctionne, mais si le même rapport est généré à partir de la méthode de travail Quartz .net, l'appel ne revient jamais.

exemple de code est ici:

//client is an instance of MessageRequestClient class 
var response = await client.Request(new GetEntityCommand 
     { 
      Ids = ids, 
      ExcludeDeleted = excludeDeleted 
     }).ConfigureAwait(false); 

Code de la consommation:

public class GetEntityCommandConsumer : IConsumer<IGetEntityCommand> 
{ 
    private readonly IEntityService _entityService; 

    public GetEntityCommandConsumer(IEntityService entityService) 
    { 
     _entityService= entityService; 
    } 

    public Task Consume(ConsumeContext<IGetEntityCommand> context) 
    { 
     var ids = context.Message.Ids; 
     var entities = _entityService.GetAll(ids, context.Message.ExcludeDeleted); //database NHibernate call 
     var result = 
      context.RespondAsync(new GetEntityCommandResponse 
      { 
       Success = true, 
       Entities = entities.Select(x => x.ToDTO).ToList() 
      }); 

     return result; 
    } 
} 

Answer 1

Comme problème habituel était dans mon propre code :) Il y avait deux cas de IBusControl mais attend qu'un seul. IBusControl qui a été utilisé à partir du travail n'a pas été démarré. Correction en utilisant "true" singletoned IBusControl.

Answer 2

Il ressemble à l'appel des consommateurs n'est pas attendu et la portée se disposée avant de terminer si vous obtenez une impasse.

Essayez ceci:

public async Task Consume(ConsumeContext<IGetEntityCommand> context) 
{ 
    var ids = context.Message.Ids; 
    var entities = _entityService.GetAll(ids, context.Message.ExcludeDeleted); //database NHibernate call 
    await 
     context.RespondAsync(new GetEntityCommandResponse 
     { 
      Success = true, 
      Entities = entities.Select(x => x.ToDTO).ToList() 
     }); 
}