Apache Camel：在文件传输后获取移动路径

Question

我正在创建一个文件传输路径，该路径使用移动来设置一个动态路径，在成功传输文件后，文件将在该路径中移动。我还设置了一个通知程序来跟踪文件传输事件。

由于移动路径是动态的，我需要得到文件传输后移动文件的路径。该路径如何在通知程序中显示？

public class MyFtpServiceBuilder extends RouteBuilder {

    @Override
    public void configure() throws Exception {

        getContext()
            .getManagementStrategy()
            .addEventNotifier(new MyFtpServiceNotifier());

        from("file:C:/tmp/inputfolder?move=archive/${date:now:yyyyMMdd}/${file:onlyname}")
            .routeId("myRoute")
            .to("file:C:/tmp/outputfolder")

    }
}

public class MyFtpServiceNotifier extends EventNotifierSupport {

    @Override
    public void notify(EventObject event) throws Exception {
        Exchange exchange = ((AbstractExchangeEvent) event).getExchange();

        if (event instanceof ExchangeSentEvent) {

            // Want to get here the path where file was moved

        }
    }

    @Override
    public boolean isEnabled(EventObject event) {
        return event instanceof AbstractExchangeEvent;
    }
}

Answer 1

我不知道如何在通知程序中执行此操作，但您始终可以添加处理器并使用FileEndpoint。getMove（）。evaluate（）方法获取最终移动的文件路径。

例如：

@Override
public void process(final Exchange exchange) throws Exception {

    File movedFile = null;
    if (exchange.getFromEndpoint() instanceof FileEndpoint) {
        FileEndpoint fileEndpoint = (FileEndpoint) exchange.getFromEndpoint();
        String movePath = fileEndpoint.getMove().evaluate(exchange, String.class);
        File inputDir = fileEndpoint.getFile();
        movedFile = new File(inputDir, movePath);
    }

}

Answer 2

您可以尝试向exchange添加标头，例如：

。setHeader（“FILE\u PROCESSED”）。简单（“存档/${日期：现在：yyyyymmdd}/${文件：onlyname}”）