时间戳

首页 > 解决方案 > Apache Camel 进程方法没有被调用

java - Apache Camel 进程方法没有被调用

问题描述

我有一个包含大约 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());

    }   

}

在输出中它只打印

内部配置方法。

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

标签： javaapache-camel

解决方案

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

此外，您的应用程序仅运行 4 秒，因为您只为此而睡觉。

推荐阅读