我有這條駱駝路線：final String URI_FILE = "file:{{PATH}}";final String POOLER = "&scheduler=quartz2&scheduler.cron=0+0/10+*+*+*+?";from(URI_FILE + POOLER).pollEnrich().simple("{{URL_CHECKER}}",String.class).aggregationStrategy(new myEstratey()).choice() .when(exchangeProperty("CONTINUE").isEqualTo(true)) .log("Condition was met") .to(URI_DIRECT) //To another route .endChoice() .otherwise() .log("I'll try again later") .to(URI_FILE) .endChoice();我想每10 分鐘從PATH讀取一個文件，然后使用 pollEnrich 檢查條件。如果滿足條件，路由繼續。在另一種情況下，我想將文件返回到同一目錄 ( PATH )。這條路線工作正常，甚至顯示日志消息“我稍后再試”，但在那之后，文件就消失了，沒有返回到PATH怎么了？在駱駝中不允許這樣做嗎？謝謝??！
1 回答
MM們
TA貢獻1886條經驗 獲得超2個贊
該文件很可能在目標目錄中被覆蓋，但是在完成后，它被移動到.camel目錄中。
這是預期的行為，請參閱文件組件文檔：
路由完成后（發布命令）執行任何移動或刪除操作
最好回滾你的路由，它默認將文件保存在源目錄中。
final String URI_FILE = "file:{{PATH}}";
final String POOLER = "&scheduler=quartz2&scheduler.cron=0+0/10+*+*+*+?";
from(URI_FILE + POOLER)
.pollEnrich().simple("{{URL_CHECKER}}",String.class).aggregationStrategy(new myEstratey())
.choice()
.when(exchangeProperty("CONTINUE").isEqualTo(true))
.log("Condition was met")
.to(URI_DIRECT) //To another route
.endChoice()
.otherwise()
.log("I'll try again later")
.rollback() // rollback processing and keep file in original directory
.endChoice();
添加回答
舉報
0/150
提交
取消