Есть ли поддержка для обязательного флага RabbitMQ в MassTransit

Question

Я хотел бы получить исключение при отправке на биржу RabbitMQ с использованием MassTransit, если сообщение не доставлено в какие-либо очереди. Похоже, что обязательный флаг RabbitMQ можно использовать для чего-то подобного, но я не смог найти способ установить это с помощью MassTransit. Поддерживается ли это?

Мой код:

var personSendEndpoint = busControl.GetSendEndpoint(new Uri($"rabbitmq://localhost/{personQueueName}")).Result; 

// An exception should occur on the following call if the message is not delivered to any queue 
personSendEndpoint.Send(new PersonUpdated() { Name = "Dorian Gray", Key = Guid.NewGuid() }); 

Answer 1

Вы можете установить Mandatory флаг, но не мило методы расширения, чтобы сделать это для вас. В принципе, вы, как показано ниже:

await endpoint.Send(new PersonUpdate(...), context => 
{ 
    (context as RabbitMqSendContext).Mandatory = true; 
}); 

И это будет установить флаг выразительный RabbitMQ бросить исключение, если нет привязки для обмена не существует.