使用Camel Stream组件

x33g5p2x  于2022-09-28 转载在 其他  
字(1.0k)|赞(0)|评价(0)|浏览(341)

stream Camel 组件 提供对 System.in、System.out 和 System.err 流的访问,并允许文件和 URL 的流式传输。

使用流组件时,可以使用以下 URI 语法:

  • stream:in[?options]
  • stream:out[?options]
  • stream:err[?options]
  • stream:header[?options]

在以下示例中,我们使用 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");
  }
});

相关文章

微信公众号

最新文章

更多