Apache Camel 进程方法未被调用

Question

我有一个包含大约 20 条记录的 csv 文件。我的目标是逐条记录地读取 csv 文件，将其转换为 XML 并将 XML 作为消息发送到 ActiveMQ 队列。我正在使用 Apache Camel 执行此操作。

第一步：读取 csv 文件并使用 Apache Camel 将其转换为 XML。

下面是代码：

    CamelContext _ctx = new DefaultCamelContext(); 
            _ctx.addRoutes(new RouteBuilder() {

                public void configure() throws Exception {
                    System.out.println("Inside configure method.");
                    from("file:src/main/resources/data-sample.csv")
                    .process(new MyTransform())
                    .to("file:src/main/resources/fileName=emp.xml");
                }

            });

            _ctx.start();
             Thread.sleep(4000);
            _ctx.stop();

class MyTransform implements Processor {

    public void process(Exchange exchange) throws Exception {

        System.out.println("In Process method");

        String myString = exchange.getIn().getBody(String.class);
        String[] lineSeparator = myString.split(System.getProperty("line.separator"));
        StringBuffer sb = new StringBuffer();

        for (String lineData : lineSeparator){

            String[] commaSeparator = lineData.split(",");
            sb.append("<equityFeeds>");
            sb.append("<externalTransactionId>" + commaSeparator[0].toString() + "</externalTransactionId>");
            sb.append("<clientId>" + commaSeparator[1].toString() + "</clientId>");
            sb.append("<securityId>" + commaSeparator[2].toString() + "</securityId>");
            sb.append("<transactionType>" + commaSeparator[3].toString() + "</transactionType>");
            sb.append("<transactionDate>" + commaSeparator[4].toString() + "</transactionDate>");
            sb.append("<sourceSystem>" + commaSeparator[5].toString() + "</sourceSystem>");
            sb.append("<priorityFlag>" + commaSeparator[6].toString() + "</priorityFlag>");
            sb.append("</equityFeeds>");

        }

        System.out.println("MyProcessor complete");
        exchange.getIn().setBody(sb.toString());

    }   

}

在输出中它只打印

Inside configure method.

未调用处理方法。为什么？怎么了？请指导我。这太烦人了。请帮忙。

Answer 1

只需说 from("file:src/main/resources/") 作为它的起始目录。如果您只想获取特定文件，请说 from("file:src/main/resources?fileName=data-sample.csv")

此外，您的应用程序仅运行 4 秒，因为您只为此休眠。

Apache Camel 进程方法未被调用

Apache Camel process method is not getting called

java

apache-camel