Spring AMQP: Abfangen jeder eingehenden und ausgehenden Nachricht

Question

Gibt es eine Möglichkeit, jede eingehende und ausgehende Nachricht mit Spring Spring AMQP abzufangen? Etwas wie Filter im Servlet-Kontext.

Answer 1

Feder AMQP hat eine Schnittstelle MessagePostProcessor; Der Listener-Container() kann mit einem oder mehreren afterReceivePostProcessors konfiguriert werden, die zum Erfassen (oder Bearbeiten) der Nachricht verwendet werden können.

Ähnlich hat die RabbitTemplatebeforePublishPostProcessors und afterReceivePostProcessors.

Wir verwenden diesen Mechanismus beispielsweise für die Komprimierung (zip outbound unzip inbound).