Параметры коннекторов

Factory

Идентификатор используемой фабрики с предустановленным значением (MONGO :: IN / MONGO :: OUT).

Display name

Отображаемое имя коннектора.

Description

Поле для краткого описания.

Classifier

Уникальный идентификатор коннектора.

Run Exclusive

Чек-бокс, активирующий запуск только на одном узле кластера.

Pre-Route

Входной коннектор. Настройка обработки сообщений перед их дальнейшей маршрутизацией во входной поток профиля.

Pre-Output

Выходной коннектор. Настройка обработки сообщений перед их дальнейшей маршрутизацией в принимающую систему.

Generate logging key

Чек-бокс, активирующий создание ключа логирования, который будет использоваться для отслеживания обработки запроса.

Ключ может включать такие параметры, как: ${exchangeProperty.requestId}, ${exchangeProperty.service}, ${exchangeProperty.operation}, ${exchangeProperty.objectId}, ${exchangeProperty.parameter}, ${exchangeProperty.sender}, ${exchangeProperty.receiver}.

Connection

Выбор используемой коннекции.

Process response

Чек-бокс активирующий обработку ответа перед его дальнейшей маршрутизацией в отправляющую систему.

Response route

Настройка обработки ответа перед его дальнейшей маршрутизацией в систему отправки.

Default target system

Название профиля принимающей системы (System name).

Название

Описание

Lazy Start Producer

Определяет, следует ли откладывать инициализацию продюсера до момента получения первого сообщения. Ленивый запуск позволяет CamelContext и маршрутам запускаться даже в тех случаях, когда немедленная инициализация продюсера может привести к сбою и прервать запуск маршрута. При ленивой инициализации возможные ошибки можно обработать с помощью маршрутизируемых обработчиков ошибок Camel при первом обращении к продюсеру. Следует учитывать, что инициализация и запуск продюсера при первом сообщении могут занять больше времени, что увеличит общее время обработки.

Название

Описание

Bridge Error Handler

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

Consumer Type

Тип потребителя.

Название

Описание

Basic Property Binding

Параметр определяет, следует ли компоненту использовать базовое связывание свойств (Camel 2.x) или более новое связывание свойств с дополнительными возможностями.

Cursor Regeneration Delay

Доступные курсоры MongoDB будут блокироваться до тех пор, пока не поступят новые данные. Если новые данные не поступают, курсор будет автоматически освобожден и закрыт сервером MongoDB после определенного времени. Ожидается, что клиент при необходимости восстановит курсор. Это значение определяет время ожидания перед попыткой получить новый курсор, а также время до следующей попытки в случае неудачи. Значение по умолчанию — 1000 мс.

Dynamicity

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

Read Preference

Настраивает, как клиенты MongoDB направляют операции чтения к членам набора реплик. Возможные значения: PRIMARY, PRIMARY_PREFERRED, SECONDARY, SECONDARY_PREFERRED или NEAREST.

Synchronous

Определяет, должно ли строго использоваться синхронное выполнение, или Camel может использовать асинхронное выполнение (если поддерживается).

Write Concern

Настраивает соединение с MongoDB, определяя уровень подтверждения, запрашиваемого для операций записи в отдельный mongod, репликацию или кластер. Возможные значения: ACKNOWLEDGED, W1, W2, W3, UNACKNOWLEDGED, JOURNALED или MAJORITY.

Write Result As Header

При операциях записи определяет, следует ли передавать сообщение IN в OUT вместо возврата WriteResult в качестве тела сообщения OUT, при этом WriteResult будет добавлен в качестве заголовка.

Название

Описание

Collection

Устанавливает имя коллекции MongoDB, с которой будет связан этот эндпоинт.

Collection Index

Устанавливает индекс коллекции в формате JSON: { field1: order1, field2: order2 }.

Create Collection

При установке чек-бокса во время инициализации создается коллекция, если она не существует.

Database

Устанавливает имя целевой базы данных MongoDB.

Operation

Параметр, задающий операцию, которую данный эндпоинт будет выполнять в MongoDB.

Output Type

Параметр, который преобразует вывод продюсера в указанный тип: DocumentList, Document или MongoIterable. Использование DocumentList или MongoIterable применяется к операциям findAll и aggregate, в то время как Document применяется ко всем другим операциям. Этот параметр позволяет настроить формат вывода в зависимости от требований к обработке данных.

Название

Описание

Exception Handler

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

Exchange Pattern

Устанавливает шаблон обмена, который используется при создании обмена потребителем.

Возможные варианты:
InOnly: Сообщение отправляется без ожидания ответа.
InOut: Сообщение отправляется с ожиданием ответа.
InOptionalOut: Сообщение может быть отправлено с ожиданием ответа, но ответ не является обязательным.

Название

Описание

Stream Filter

Задает условие фильтрации для потребителей, работающих с потоками изменений.

Название

Описание

Persistent Id

Уникальный идентификатор, назначаемый каждому трекеру в коллекции для отслеживания хвостов (tail tracking collection). Это позволяет нескольким трекерам, обслуживающим множество потребителей с хвостовым отслеживанием, эффективно разделять данные и избегать конфликтов.

Persistent Tail Tracking

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

Tail Track Collection

Коллекция, в которой сохраняется информация об отслеживании хвостов. Если конкретная коллекция не указана, по умолчанию будет использоваться коллекция, определенная в MongoDbTailTrackingConfig#DEFAULT_COLLECTION.

Tail Track Db

Параметр указывает, в какую базу данных будет сохраняться информация об отслеживании хвостов. Если конкретная база данных не указана, по умолчанию будет выбрана текущая база данных. Динамичность не будет учитываться: даже если она включена, база данных для отслеживания хвостов не изменится после инициализации конечной точки.

Tail Track Field

Поле, в котором будет сохранено последнее отслеживаемое значение. Если поле не указано, по умолчанию будет использовано значение из MongoDbTailTrackingConfig#DEFAULT_FIELD.

Tail Track Increasing Field

Поле корреляции во входной записи, которое имеет возрастающий характер и используется для позиционирования курсора при каждом его создании. Курсор будет пересоздан с помощью запроса, где значение tailTrackIncreasingField больше последнего значения, возможно восстановленного из постоянного отслеживания. Поле может иметь тип Integer, Date, String и т. д.

ПРИМЕЧАНИЕ: В настоящее время не поддерживается dot-нотация, поэтому поле должно находиться на верхнем уровне документа. Это гарантирует корректное отслеживание изменений и их последовательность.