jms - 如何拦截一个jms入站网关的回复消息

Question

我有一个 jms-inbound-gateway，它从 WebsphereMQ 代理读取请求，将它们传递给我的集成系统，然后回复一条响应消息。

我需要记录设置了 jms_messageId 和 jms_correlationId 标头的消息，因此我可以匹配日志文件中的请求/回复消息（并在他说我的响应没有正确的 jms_correlationId 时将其显示给我的客户）

设置correlationId标头后，有没有办法拦截方法producer.sendReply(...)？

Answer 1

那里不需要拦截；标头在到达网关之前在网关回复消息中的 Spring Integration 消息中可用。

只需制作reply-channelapublish-subscribe-channel并添加一个<logging-channel-adapter/>将其作为输入通道的 a。

回复消息将被发送到网关和记录器。

如果您使用默认机制来路由回复（output-channel最后一个集成组件上没有），只需添加一个output-channel并路由到回复通道。

Answer 2

这是加里输入后我的解决方案的要点：

<jms:inbound-gateway 
    id="inboundDestination" 
    connection-factory="connectionFactory"  
    request-destination="nmRequestsQueue" 
    request-channel="request-begin" 
    reply-channel="request-end" 
    error-channel="normaErrorChannel" 
    concurrent-consumers="1" 
    acknowledge="transacted" />

<int:logging-channel-adapter id="request-response-logger"
        log-full-message="true"
        level="DEBUG" 
        logger-name="com.audaxys.si.messages" />

<int:channel id="request-begin">
    <int:interceptors>
        <int:wire-tap channel="request-response-logger" />
    </int:interceptors>
</int:channel>

<int:chain input-channel="request-begin" output-channel="request-end">
    ... Do Stuff ...
</int:chain>

<int:publish-subscribe-channel id="request-end">
    <int:interceptors>
        <int:wire-tap channel="request-response-logger" />
    </int:interceptors>
</int:publish-subscribe-channel>