2011-09-15 53 views
1

我正在使用Websphere Message Broker处理csv文件并将数据放入消息队列中。该文件通过FileInputNode读入,通过JavaCompute节点(用于验证)传递,然后将消息映射映射到目标格式,然后映射到JMSOutput节点。Websphere Message Broker - FileInput节点 - 标头值

我遇到的问题是,csv中的第一行有一个值,我需要添加到每个出站消息(第一行是头,所以不会输出到队列中)。我有点卡住如何做到这一点,因为我看不到我如何可以优雅地将第一行的值映射到所有后续行。

我已经尝试在使用JavaCompute节点的LocalEnvironment上保留值,但这似乎在行之间丢失(顺便说一句,我正在逐行处理文件,这是在fileinput节点上设置的,因此整个流程是通过每个记录)。

任何提示如何实现这一点,将不胜感激。

巴里

回答

0

只是一个想法,但如果你的值加载到流定义的共享变量,它不应该被流动的行/执行之间迷失在你的LocalEnvironment想法的情况下。 ..真的很简单的第一遍思想,因为我还没有尝试过。

相关问题