MD5 как идемпотентКей в Apache Camel - PullRequest
0 голосов
/ 12 февраля 2019

Поведение по умолчанию состоит в том, что абсолютный путь к файлу используется для уникальной идентификации файлов - я хотел бы настроить его для использования контрольной суммы md5 файла.

Можно ли просто реализовать собственный idempotentKey (чтоне использует «File File»)?

1 Ответ

0 голосов
/ 12 февраля 2019

Компонент Camel File2 поддерживает вставные выражения.Создайте bean-компонент, реализующий Expression и передайте его по маршруту с idempotentKey=#myExpressionBean.


Я не думаю, что это хорошая идея - вычислять хэш md5 содержимого файла для каждого опроса,но это возможно.

Выражение

@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);
        }
    }
}

Потребитель

from("file://somewhere?idempotent=true&idempotentKey=#fileContentMD5Expression")
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...