为审计目的重载MessageHistory对象

Question

我需要审计通过spring-integration流程传递的每一条消息，这是非常基本的。

应用程序从int redis:queue入站通道适配器读取，并写入int http:outbound网关。

输出网关有一个回复通道，以便接收超文本传输协议方法的响应，就是在这个确切的时刻，当我想注册de审核信息时，包括初始消息和超文本传输协议响应。

如果http方法失败，消息将转到errorHandler，我可以获得带有时间戳和有效负载的history对象，这非常适合审计。

但是，如果 http 方法有效（代码 200，201 ...），我会收到一条消息，其中包含带有状态代码的 ResponseEntity 对象，但我没有来自 redis 的初始有效负载。

那么，有没有办法将这两条消息（在向外发送超文本传输协议之前和超文本传输协议响应之后）关联起来，以便获得用于审计的完整信息？

提前感谢！

以下是集成流程：

<int:message-history/>

<int:channel id="responseChannel"/>

<int:channel id="responseError"/>

<int:logging-channel-adapter channel="responseChannel" level="INFO" 
   expression="@messageHandlerSpel.handle( #this )" id="logger"/>

<int:logging-channel-adapter channel="responseError"
    level="ERROR" expression="@errorHandlerSpel.handle( #this )"
    id="LogingERROR"/>

<int-redis:queue-inbound-channel-adapter id="inputRedis" connection-factory="redisCF" 
   channel="redisInput" queue="redis-input" serializer="" error-channel="responseError"/>

<int:channel id="redisInput" />

<int-http:outbound-gateway id="HttpOutbound" request-channel="redisInput" 
   url="http://{server}:{port}/{index}/{type}/{id}" 
   http-method="PUT" extract-request-payload="true" charset="UTF-8" 
   reply-channel="responseChannel" request-factory="requestFactory"/>

以及处理程序类：

@Component
public class MessageHandlerSpel {
    public String handle(Message<byte[]> message) {
        MessageHeaders msgH = message.getHeaders();
        MessageHistory msgHistory = 
            message.getHeaders().get(MessageHistory.HEADER_NAME, MessageHistory.class);
        ... // Do whatever
    return "";
}

Answer 1

一个技巧是在执行HTTP请求之前将请求有效负载存储在自定义标头中。

收到响应后，请求标头将与该响应负载合并。因此，在下游，您将同时拥有两者：标头中的请求和有效负载中的回复。

消息历史保持不变，没有理由以某种方式破解那里。

另一种方法基于

通过以下方式简单地复制/粘贴到标题:

<header-enricher>
    <header name="requestPayload" expressio="payload"/>
</header-enricher>

应该够你用了。