Description
I am trying to invoke an MessagePostProcessor
to apply/verify a header before sending/after receiving an message.
I have managed to add the PostProcessor functionality for following situations:
- Before send (in publisher)
- After receive (in publisher)
- After receive (in consumer with an AdviceChain, but I do not think that this is the meant sollution)
But I am not able to set it up for sending reply. When looking into the code I can see that the reply is handled inside the AbstractAdaptableMessageListener
where an replyPostProcessor
is available.
But this replyPostProcessor
never is set, so it is always null and because of that never executed.
Little bit more detail:
The AbstractAdaptableMessageListener
is created in the MethodRabbitListenerEndpoint.createMessageListener
method. After creating a new MessagingMessageListenerAdapter
replyToAddress
, messageConverter
and beanResolver
are set and the listener is returned. I think that here the replyPostProcessor
also should be set, too.
But I do not have this great understanding of the code to say this for sure.
The version I am using is 1.7.6.RELEASE