MassTransitは、私は2人の消費者を持っている_errorキュー

Question

を作成しない：同じ構成で

public class SendEmailConsumer : ConsumerBase, IConsumer<ISendEmail> 
    {  
     public Task Consume(ConsumeContext<ISendEmail> context) 
     { 
      throw new Exception("aaa"); 
     } 
    } 




public class IntegrateNewCostCenterConsumer: ConsumerBase, IConsumer<IIntegrateCostCenter> 
     {  
      public Task Consume(ConsumeContext<ISendEmail> context) 
      { 
       throw new Exception("aaa"); 
      } 
     } 

両方：

cfg.ReceiveEndpoint(host, MessageHandlerConstants.IntegrateCostCenter, e => 
      { 
       // doc http://masstransit-project.com/MassTransit/advanced/middleware/circuit-breaker.html 
       e.UseCircuitBreaker(cb => 
       { 
        cb.TripThreshold = 15; 
        cb.ResetInterval = TimeSpan.FromMinutes(5); 
        cb.TrackingPeriod = TimeSpan.FromMinutes(1); 
        cb.ActiveThreshold = 10; 
       }); 

       e.UseRetry(r => r.Interval(5, new TimeSpan(0, 0, 10))); 
       e.Consumer<IntegrateNewCostCenterConsumer>(); 
      }); 


cfg.ReceiveEndpoint(host, MessageHandlerConstants.SendEmail, e => 
      { 
       // doc http://masstransit-project.com/MassTransit/advanced/middleware/circuit-breaker.html 
       e.UseCircuitBreaker(cb => 
       { 
        cb.TripThreshold = 15; 
        cb.ResetInterval = TimeSpan.FromMinutes(5); 
        cb.TrackingPeriod = TimeSpan.FromMinutes(1); 
        cb.ActiveThreshold = 10; 
       }); 

       e.UseRetry(r => r.Interval(10, new TimeSpan(0, 0, 60))); 
       e.Consumer<SendEmailConsumer>(); 
      }); 

問題はIntegrateCostCenterは、例外のsucessfuly作成_errorキューを持っているだけです。両方とも正常に処理されます。私は間違っているの？すべての試みが失敗した場合にのみ、エラー・キューが作成され

Answer 1

。