java - 如何正确记录 Camel 中的消息/路由(流)？

Question

我正在使用 Apache Camel 将一些 SOAP 消息从 A 路由到 B。

我想为某些特定路由添加日志记录，但问题是消息正文是一个流。

我的解决方案是将该流转换为字符串，然后将其发送到端点 B。

这似乎工作正常，但我不确定这个方法有多干净？

这就是我现在的路线:

<route>
    <from uri="cxf:bean:ServiceA?dataFormat=MESSAGE" />
    <convertBodyTo type="java.lang.String"/>
    <to uri="log:my.company?level=WARN"/>
    <to ref="ServiceB" />
</route>

问题是我是否应该使用wireTap和流缓存来复制流，将其转换为字符串，记录它并将其他未触及的流发送到ServiceB。我找不到正确的方法。这是我的尝试:

<route streamCache="true">
    <from uri="cxf:bean:ServiceA?dataFormat=MESSAGE" />
    <wireTap uri="log:my.company?level=WARN" /> <!-- how to convert this stream to a string? -->
    <to ref="ServiceB" />
</route>

所以，你说什么？ WireTap 还是上述解决方案？

Answer 1

您只需在日志端点上启用 showStreams=true 选项即可。然后它也会记录流；在此之前你不需要转换 body 。不过，您仍然需要启用流缓存，以确保稍后当您继续处理消息时可以重新读取流。

请参阅日志组件文档中的选项: http://camel.apache.org/log