我只想允许从源目录中删除非重复文件。我有一条这样的幂等消费者的路线:File repo = new File("repo.txt");IdempotentRepository fr = FileIdempotentRepository.fileIdempotentRepository(repo);from("sftp:someServer:somePort/someDir?delete=true") .idempotentConsumer(header("CamelFileName"),fr) .to("file:output");在这种情况下,delete=true 将导致从源目录中删除重复消息的路由。为了防止这种情况,我尝试了以下代码:File repo = new File("repo.txt");IdempotentRepository fr = FileIdempotentRepository.fileIdempotentRepository(repo);from("sftp:someServer:somePort/someDir?delete=true") .idempotentConsumer(header("CamelFileName"),fr) .skipDuplicate(false) .filter(exchangeProperty(Exchange.DUPLICATE_MESSAGE).isEqualTo(true)) .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { exchange.setException(new InterruptedException("Cancel Exchange")); exchange.setProperty(Exchange.ROUTE_STOP, Boolean.TRUE); } }) .end().to("file:output");由于从路由内的 sftp 删除将需要另一个 jsch 实例,因此我希望能够使用 sftp 使用者的删除属性
添加回答
举报
0/150
提交
取消