Функциональные компоненты
File Watch

File Watch

Поддерживается только потребитель

Этот компонент можно использовать для наблюдения за событиями изменения файлов в папке.

Configuring Options

Компоненты настраиваются на двух отдельных уровнях:

  • component level

  • edpoint level

Configuring Component Options

На уровне компонента задаются основные и общие настройки, которые впоследствии наследуются endpoints. Это самый высокий уровень конфигурации.

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

Некоторые компоненты имеют всего несколько параметров, в то время как у других их может быть много. Поскольку компоненты обычно имеют предварительно настроенные значения по умолчанию, которые используются в большинстве случаев, вам может понадобиться настроить только несколько параметров компонента или вообще ничего не настраивать.

Компоненты можно настроить с использованием:

  • Component DSL.

  • Конфигурационного файла (application.properties, *.yaml files, etc).

  • Напрямую в Java code.

Configuring Endpoint Options

Обычно больше времени уходит на настройку endpoints, так как они обладают множеством параметров. Эти параметры позволяют настроить поведение endpoint в соответствии с вашими потребностями. Кроме того, параметры делятся на категории в зависимости от того, используется ли endpoint как потребитель (from), как производитель (to) или в обеих ролях.

Настройка endpoints чаще всего выполняется непосредственно в URI endpoint в виде параметров пути и запроса. Также вы можете использовать Endpoint DSL и DataFormat DSL как типобезопасный способ настройки endpoints и форматов данных в Java.

Хорошей практикой при настройке параметров является использование Property Placeholders.

Property placeholders предоставляют несколько преимуществ:

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

  • Позволяют вынести конфигурацию за пределы кода.

  • Делают код более гибким и удобным для повторного использования.

Component properties

Ant Include

  • Шаблон в стиле ANT для поиска файлов. Он применяется к пути файла относительно корневого пути endpoint и не должен начинаться с символа "/".

  • По умолчанию: **

  • Тип: String

Auto Create

  • Автоматически создает директорий, если он не существует.

  • По умолчанию: true

  • Тип: boolean

Concurrent Consumers

  • Количество параллельных потребителей. Увеличьте это значение, если ваш маршрут работает медленно, чтобы предотвратить буферизацию в очереди.

  • По умолчанию: 1

  • Тип: int

Events

  • Разделенный запятыми список событий для отслеживания. Возможные значения: CREATE, MODIFY, DELETE.

  • По умолчанию: CREATE,MODIFY,DELETE

  • Тип: String

File Hasher

  • Ссылка на io.methvin.watcher.hashing.FileHasher. Это предотвращает дублирующиеся события на некоторых платформах. Для работы с большими файлами, если нет необходимости отслеживать несколько изменений в секунду для одного файла, используйте #lastModifiedTimeFileHasher. Также можно предоставить собственную реализацию в реестре.

  • По умолчанию: #murmur3FFileHasher

  • Тип: FileHasher

Path

  • Обязательный параметр: путь к директорию, из которого будут потребляться события.

  • По умолчанию:

  • Тип: String

Poll Threads

  • Количество потоков, опрашивающих WatchService. Увеличьте это значение, если в логах появляются сообщения OVERFLOW.

  • По умолчанию: 1

  • Тип: int

Queue Size

  • Максимальный размер очереди между WatchService и потребителем. По умолчанию не ограничен.

  • По умолчанию: 2147483647

  • Тип: int

Recursive

  • Отслеживать рекурсивно в текущем и вложенных директориях (включая новые директории).

  • По умолчанию: true

  • Тип: boolean

Use File Hashing

  • Включает или отключает хеширование файлов для обнаружения дублирующихся событий. Если отключить эту опцию, на некоторых платформах и версиях JDK возможно получение одних и тех же событий несколько раз.

  • По умолчанию: true

  • Тип: boolean

Component advanced properties

Bridge Error Handler

  • Предоставляет возможность связать потребителя с маршрутизатором Error Handler Camel. Это позволяет обрабатывать исключения (если возможно), возникающие при получении входящих сообщений потребителем Camel, в виде сообщений, передаваемых в маршрутизатор Error Handler.

    Важно: Это возможно только в том случае, если сторонний компонент позволяет Camel получать уведомления о возникших исключениях. Некоторые компоненты обрабатывают исключения только внутренне, из-за чего использование bridgeErrorHandler становится невозможным. В некоторых случаях мы можем доработать компонент Camel, чтобы интегрировать его со сторонним компонентом и сделать такую возможность доступной в будущих выпусках. По умолчанию потребитель использует org.apache.camel.spi.ExceptionHandler для обработки исключений, которые логируются с уровнем WARN или ERROR и игнорируются.

  • По умолчанию: false

  • Тип: boolean

Exception Handler

  • Позволяет потребителю использовать собственный ExceptionHandler.

    Обратите внимание, что если включена опция bridgeErrorHandler, то эта настройка не используется. По умолчанию потребитель обрабатывает исключения, которые логируются с уровнем WARN или ERROR и игнорируются.

  • По умолчанию:

  • Тип: ExceptionHandler

Exchange Pattern

  • Определяет шаблон взаимодействия, который применяется, когда потребитель создает новый обмен (exchange).

    Возможные значения:

    • InOnly

    • InOut

  • По умолчанию:

  • Тип: ExchangePattern

FileFlatpack