MassTransit에 RabbitMQ 필수 플래그가 지원됩니까?

Question

메시지가 대기열로 전달되지 않으면 MassTransit을 사용하여 RabbitMQ 교환에 보낼 때 예외를 얻고 싶습니다. 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를 설정합니다.