Spring AMQPでインターセプタを使用する方法

Question

メッセージがRabbitMQに配信される前に、template.convertAndSendが呼び出されると、メッセージを傍受する方法はありますか？

また、ハンドラに到達する前にメッセージを傍受する方法はありますか？

パブリッシャー用のPostProcessorを使用してメッセージを処理できますが、インターセプターを使用することをお勧めします。

public class TestPostProcessor implements MessagePostProcessor { 

    @Autowired 
    Tracer defaultTracer; 

    @Override 
    public Message postProcessMessage(Message message) throws AmqpException { 
     //..... 
     //.... 
     return message; 
    } 
} 

Answer 1

MessagePostProcessorはインターセプタの一種です。

MPPを引数とするオーバーロードされたconvertAndSend()メソッドのうちの1つを使用する方法と、setBeforePublishPostProcessors()を使用してRabbitTemplateに1つ以上を追加する方法の2つがあります。

メソッドから受信したメッセージが返される前に呼び出されるsetAfterReceivePostProcessors()を使用して、受信したメッセージを傍受することもできます。

リスナーコンテナは、受信後、リスナへの配信前に、setAfterReceivePostProcessors()メソッドを使用してMPPをサポートします。