MassTransit/RabbitMQ 中的消息持久性

Question

我有 2 个应用程序，一个是事件发布应用程序，一个是事件消费者应用程序。 发布者使用 SimpleInjector：

container.AddMassTransit(x =>
{
    x.AddBus(() => Bus.Factory.CreateUsingRabbitMq(cfg =>
    {
        var host = cfg.Host(ConfigurationValuesProvider.Current.Get("RabbitHostName"), hostConfigurator =>
        {

        });

    }));
});

消费者使用 CastleWindsor：

container.AddMassTransit(x =>
{
    x.AddBus(context => Bus.Factory.CreateUsingRabbitMq(cfg =>
    {
        var host = cfg.Host(configurationProvider.RabbitHostName);

        x.AddConsumer<FactAddedHandler>();
        x.AddConsumer<FactAddedWebhookHandler>();
        x.AddConsumer<FactMonitorHandler>();

        cfg.ConfigureEndpoints(container);
    }));

});

一切正常，尽管我尝试通过 consumer 注册使我发布的一些消息不耐久：

x.AddConsumer<FactAddedHandler>().Endpoint(e =>
{
    e.Temporary = true;
});

通过这种方式，队列被标记为临时队列，并在应用程序关闭后立即被删除。但我只希望消息不持久，我希望队列在应用程序出现故障时仍处于启动状态并准备就绪。有没有办法做到这一点？

Answer 1

显然，我不认为 e.Temporary = true; 正在做你认为它会做的事情。

配置端点时，传递给配置函数的配置器是一个相当通用的交叉代理IReceiveEndpointConfigurator。如果您想配置一些特定于代理的东西，您可以强制转换为特定于代理的配置器。例如，对于 RMQ：

x.AddConsumer<FactAddedHandler>().Endpoint("my_queue", e =>
{
  if (e is IRabbitMqReceiveEndpointConfigurator r)
  {
    r.Durable = false;
  }
});

请注意，如果您没有在此处指定队列名称，那么无论如何您最终都会得到一个 MT“临时队列”，该队列将被唯一命名并在您的应用程序关闭时被销毁。这可能不是你想要的。