MassTransit 未创建 _error 队列答案

【问题标题】：MassTransit not creating _error queueMassTransit 未创建 _error 队列
【发布时间】：2017-07-12 20:08:41
【问题描述】：

我有两个消费者：

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 为异常成功创建了 _error 队列。两者都正常处理。我做错了什么？

【问题讨论】：

标签： c# asp.net rabbitmq masstransit

【解决方案1】：

只有在所有尝试都失败时才会创建错误队列。

【讨论】：