By design EasyNetQ throws exception, when trying to set a custom exchange type:
Unknown exchange type 'x-delayed-message', expected one of direct, topic, fanout, headers
The problem is with this first party RabbitMQ plugin that needs a custom exchange type - https://github.com/rabbitmq/rabbitmq-delayed-message-exchange
There should probably be a way to add custom exchange types to the predefined list in ExchangeInfo.cs class.
As a workaround, I'm overriding the Type with reflection:
exchangeInfo.GetType().GetProperty(nameof(exchangeInfo.Type)).SetValue(exchangeInfo, "x-delayed-message");
By design EasyNetQ throws exception, when trying to set a custom exchange type:
Unknown exchange type 'x-delayed-message', expected one of direct, topic, fanout, headersThe problem is with this first party RabbitMQ plugin that needs a custom exchange type - https://github.com/rabbitmq/rabbitmq-delayed-message-exchange
There should probably be a way to add custom exchange types to the predefined list in
ExchangeInfo.csclass.As a workaround, I'm overriding the Type with reflection:
exchangeInfo.GetType().GetProperty(nameof(exchangeInfo.Type)).SetValue(exchangeInfo, "x-delayed-message");