Java&Apache-Camel：从直接endpoint到文件endpoint

Question

from(direct:start)
  .to(direct:doStuff)
  .to(direct:readDirectory)
  .to(file://destination-folder)

@Component
public class Route extends AbstractRouteBuilder {
  @Override
  public void configure() throws Exception {
      from("direct:start")
        .bean(lookup(ReadDirectory.class))
        .split(body())
          .setHeader("FILENAME", method(lookup(CreateFilename.class)))
          .to("file:///path/to/my/output/directory/?fileName=${header.FILENAME}");
  }

@Component
public class ReadDirectory implements CamelProcessorBean {
  @Handler
  public ImmutableList<File> apply(@Header("SOURCE_DIR") final String sourceDir) {
    final File directory = new File(sourceDir);
    final File[] files = directory.listFiles();
    if (files == null) {
      return ImmutableList.copyOf(Lists.<File>newArrayList());
    }
    return ImmutableList.copyOf(files);
  }
}

我可以通过使用以下伪测试启动路由（关键是我可以通过producer.sendbodyandheader(..))手动启动路由）

public class RouteIT extends StandardIT {
  @Produce
  private ProducerTemplate producer;

  @Test
  public void testRoute() throws Exception {
    final String uri = "direct:start";
    producer.sendBodyAndHeaders(uri, InOut, null, header());
  }

  private Map<String, Object> header() {
    final Map<String, Object> header = Maps.newHashMap();
    header.put("SOURCE_DIR", "/path/to/my/input/directory/");
    return header;
  }
}

• AbstracTrouteBuilder扩展SpringRouteBuilder
• CamelProcessorBean只是一个标记接口
• StandardIt加载SpringContext和stuft

问题是，我必须设置文件名。我读过一些camel设置headercamelFileNameProducted的东西（在文件endpoint期间）。它是一个带有时间戳的通用字符串，如果我不设置文件名-写入的文件将获得这个通用字符串作为文件名。

Answer 1

您可以在使用producer模板发送时设置文件名，只要在路由之间的路由过程中传播头部就可以了，而Camel在默认情况下是这样做的。

例如

  @Test
  public void testRoute() throws Exception {
    final String uri = "direct:start";
    Map headers = ...
    headers.put(Exchange.FILE_NAME, "myfile.txt");
    producer.sendBodyAndHeaders(uri, InOut, null, headers);
  }

文件组件更多地讨论如何控制文件名

null