Spring AMQP:拦截每条传入和传出消息
Spring AMQP: intercept every incoming and outgoing message
有没有办法使用 spring Spring AMQP 拦截每条传入和传出的消息?类似于 servlet 上下文中的过滤器。
Spring AMQP 有一个接口 MessagePostProcessor
;侦听器容器 (SimpleMessageListenerContainer
) 可以配置一个或多个 afterReceivePostProcessors
,可用于捕获(或操纵)消息。
同样,RabbitTemplate
有 beforePublishPostProcessors
和 afterReceivePostProcessors
。
我们使用这种压缩机制,例如 (zip outbound unzip inbound)。
有没有办法使用 spring Spring AMQP 拦截每条传入和传出的消息?类似于 servlet 上下文中的过滤器。
Spring AMQP 有一个接口 MessagePostProcessor
;侦听器容器 (SimpleMessageListenerContainer
) 可以配置一个或多个 afterReceivePostProcessors
,可用于捕获(或操纵)消息。
同样,RabbitTemplate
有 beforePublishPostProcessors
和 afterReceivePostProcessors
。
我们使用这种压缩机制,例如 (zip outbound unzip inbound)。