我想在Masstransit中更改交换类型。下面的示例代码块。
_bus = BusConfigurator.Instance.ConfigureBus(_massTransitSettings,
(cfg, host) =>
{
cfg.ReceiveEndpoint("example-queue",
e =>
{
e.AutoDelete = true;
e.Durable = true;
e.ExchangeType = ExchangeType.Direct;
e.Consumer(() =>
{
//consume operation
});
});
});
[进行测试时,我仍然在Rabbitmq扇出中看到交换类型的值。我在哪里犯错?
谢谢您的支持。
[C0,显示如何使用RabbitMQ和MassTransit设置直接交换路由。
交换属性的配置也为There is a sample。