Spring AMQP:拦截每条传入和传出消息

Spring AMQP: intercept every incoming and outgoing message

有没有办法使用 spring Spring AMQP 拦截每条传入和传出的消息?类似于 servlet 上下文中的过滤器。

Spring AMQP 有一个接口 MessagePostProcessor;侦听器容器 (SimpleMessageListenerContainer) 可以配置一个或多个 afterReceivePostProcessors,可用于捕获(或操纵)消息。

同样,RabbitTemplatebeforePublishPostProcessorsafterReceivePostProcessors

我们使用这种压缩机制,例如 (zip outbound unzip inbound)。