创建流式有效负载的定制骡子组件？答案

【问题标题】：Customised mule component that creates streamed payload?创建流式有效负载的定制骡子组件？
【发布时间】：2014-09-05 06:11:27
【问题描述】：

我正在尝试找到在 mule 流中创建流式有效负载的最简单、最快捷的方法。理想情况下，这将是一个 java 组件。

全部原因是我旁边有一个数据映射器，并以流模式进行映射。所以我希望这个有效载荷是一个流式 pojo 集合。我尝试只实现 Callable 接口，但我似乎很难找到一种正确的方法来输出流有效负载并让 Mule 在使用此流时继续处理流程中的下一步。

谢谢！

【问题讨论】：

【解决方案1】：

让您的组件产生一个java.io.InputStream 有效负载。

【讨论】：

这并没有提供问题的答案。要批评或要求作者澄清，请在其帖子下方发表评论。
@TomRedfern 抱歉，这是一个答案，而不是一个拙劣的问题。改写，使用“Make”而不是“Have”，因为它显然不清楚。
嗨@DavidDossot，不管你是否一直在帮助我们解决这些stackoverflow问题，谢谢。在这种特殊情况下，我们希望将流式 pojo 集合有效负载放入数据映射器并从那里映射。我遇到的挑战是如果 java 组件只是一个可调用的组件，我应该如何要求它返回一个 inputStream 有效负载并让 Mule 知道有效负载会不断出现，所以继续下一步（数据映射）？
好问题。我想 DataMapper 将正确处理流有效负载。您应该能够从onCall 返回一个InputStream，因为返回类型是Object。