stream Camel 组件 提供对 System.in、System.out 和 System.err 流的访问,并允许文件和 URL 的流式传输。
使用流组件时,可以使用以下 URI 语法:
在以下示例中,我们使用 stream:out 对文件夹 C:\Camel\In 中包含的文件内容执行 System.out
package com.sample;
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.spi.DataFormat;
public class Hello {
public static void main(String args[]) throws Exception {
CamelContext context = new DefaultCamelContext();
final DataFormat bindy = new BindyCsvDataFormat("com.sample.model");
context.addRoutes(
new RouteBuilder() {
public void configure() {
from("file:C:camelin?noop=true").to("stream:out");
}
});
context.start();
Thread.sleep(10000);
context.stop();
}
}
请注意,您可以在路由中组合不同类型的流:例如,以下 RouteBuilder 从控制台获取输入流并将其打印到 System.out 流:
context.addRoutes(new RouteBuilder() {
public void configure() {
from("stream:in").to("stream:out");
}
});
版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : http://www.masterspringboot.com/various/camel/using-camel-stream-component
内容来源于网络,如有侵权,请联系作者删除!