1 回答

TA貢獻(xiàn)1775條經(jīng)驗(yàn) 獲得超11個(gè)贊
Camel File2 組件支持可插入表達(dá)式。創(chuàng)建實(shí)現(xiàn)Expression的bean并將其傳遞給帶有idempotentKey=#myExpressionBean.
我不認(rèn)為,為每次輪詢計(jì)算文件內(nèi)容的 md5 哈希值是個(gè)好主意,但這是可能的。
表達(dá)
@Component
class FileContentMD5Expression implements Expression {
@Override
public <T> T evaluate(Exchange exchange, Class<T> type) {
if (type != String.class){
throw new IllegalArgumentException("This is String only expression");
}
try (FileInputStream fis = new FileInputStream(((File)exchange.getIn(GenericFileMessage.class).getGenericFile().getFile()))) {
return type.cast(DigestUtils.md5Hex(fis));
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
消費(fèi)者
from("file://somewhere?idempotent=true&idempotentKey=#fileContentMD5Expression")
添加回答
舉報(bào)