Тип сервиса ServiceSowaIpa#

В контексте service объявляется соответствующий тип сервиса service_sowa_ipa:

service:
  service_sowa_ipa:

Для корректной работы сервиса service_sowa_ipa рекомендуется выполнить установку в соответствии с описанием, приведенном в разделе Процесс развертывания дистрибутива в Руководстве по установке.

ServiceSowaIpa - основные параметры#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`id`	Обязательный	Идентификатор сервиса в контексте всего профиля. Используется, например, в названии директории и других системных файлах. Значение должно быть уникальным. Количество сервисов не ограничено	Текстовое значение (строка, число или их комбинация, разделитель — «_»)	—
`name`	Опциональный (обязательный, если указан `optional/event_hook`)	Технологическое название сервиса, используемое для идентификации в логах транзакций. Значение должно быть уникальным	Строковое значение	—
`profile_version`	Опциональный	Версия профиля данного сервиса	Текстовое значение	—
`description`	Опциональный	Строка с описанием сервиса. Значение не является уникальным	Текстовое значение	—
`common`	Обязательный	Группа параметров, содержащих настройки адаптера, не зависящие от требуемых направлений движения данных	Группа параметров, описанных в разделе «SowaIpa - common»	—
`mq_usock`	Опциональный	Направление MQ → unix socket потребитель (в целевой модели SOWA). Необходим, если отсутствует `usock_mq` на этом же уровне	Параметры, описанные в разделе «SowaIpa - mq_usock»	—
`usock_mq`	Опциональный	Направление unix socket → MQ. Необходим, если отсутствует `mq_usock` на этом же уровне	Параметры, описанные в разделе «SowaIpa - usock_mq»	—
`kafka_usock`	Опциональный	Направление Kafka → unix socket потребитель (в целевой модели SOWA). Необходим, если отсутствует `usock_kafka` на этом же уровне	Параметры, описанные в разделе «SowaIpa - kafka_usock»	—
`usock_kafka`	Опциональный	Направление unix socket → Kafka. Необходим, если отсутствует `kafka_usock` на этом же уровне	Параметры, описанные в разделе «SowaIpa - usock_kafka»	—

SowaIpa - common#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`logging_path`	Опциональный (deprecated)	Путь до логов данного сервиса на сервере SOWA. Параметр не учитывается при конфигурировании. Логи располагаются по адресу `/sowalogs/_profile-name_/services/service_sowa_ipa/_service-id_`. Оставлен для обратной совместимости	Строковое значение	—
`passwords_path`	Обязательный (при шифрованных протоколах)	Относительный путь до файла с паролями для SOWA (подробнее в разделе Формат заполнения файла с паролями). Путь задается относительно `/sowa/profile_storage/custom/ИМЯ_ПРОФИЛЯ/`. При конфигурировании файл вырезается из каталога и вставляется в закрытый раздел SOWA	Строковое значение	—
`logging_appender_console_level`	Опциональный	Уровень логирования консольного appender	Строковое значение	`DEBUG`
`logging_max_file_size`	Опциональный	Максимальный размер файла с логами	Строковое значение	`100MB`
`logging_max_history`	Опциональный	Максимальное количество архивных файлов логов	Строковое значение	`30`
`logging_total_size_cap`	Опциональный	Общий максимальный размер всех архивных файлов логов	Строковое значение	`2GB`
`logging_appender_async_file_queue_size`	Опциональный	Количество событий логирования в очереди для доставки	Строковое значение	`500`
`logging_package_org_springframework`	Опциональный	Категория логирования пакета org.springframework	Строковое значение	`INFO`
`logging_package_com_ibm_mq`	Опциональный	Категория логирования пакета com.ibm.mq	Строковое значение	`INFO`
`logging_package_org_apache_camel`	Опциональный	Категория логирования пакета org.apache.camel	Строковое значение	`INFO`
`logging_package_org_apache_kafka`	Опциональный	Категория логирования пакета org.apache.kafka	Строковое значение	`INFO`
`logging_package_ru_sbt`	Опциональный	Категория логирования пакета ru.sbt	Строковое значение	`INFO`
`jvm_options`	Опциональный	Список JVM-опций для запуска сервиса sowa_ipa	Список строковых значений	—

Пример:

common:
  logging_path: path/to/log
  passwords_path: path/to/passwords

SowaIpa - kafka_usock#

Группа параметров kafka_usock отвечает за взаимодействие по направлению Kafka→unix socket.

Внимание! При соединении с service_http_proxy для стабильной работы необходимо задавать:

modifiers:
  set_header:
    - Host IPA

При использовании синхронного взаимодействия, для записи в topic пары ключ-значение, ключ необходимо передавать в HTTP заголовке Kafka-KEY.

При использовании опции auto_commit = FALSE фиксация смещения происходит только после успешного прохождения маршрута (кода ответа 200).

Kafka_usock - from#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`brokers`	Обязательный	Список URL брокеров	Список (Sequence)	—
`group_id`	Обязательный	Группа, к которой принадлежит потребитель	Строковое значение	—
`topics`	Обязательный	Список тем, на которые производится подписка	Список (Sequence)	—
`auto_commit`	Обязательный	Если TRUE — автоматически фиксирует смещения. Если FALSE — фиксация после успешного прохождения маршрута	Булево значение	—
`client_id`	Опциональный	Идентификатор клиента для журналирования, отслеживания и квот	Строковое значение	—
`auto_commit_interval`	Опциональный	Интервал автоматической фиксации смещений в мс	Целочисленное значение	`5000`
`auto_offset_reset`	Опциональный	Действие при отсутствии или выходе за диапазон начального смещения	`earliest` — самое раннее; `latest` — самое позднее; `none` — исключение	`earliest`
`fetch_max_bytes`	Опциональный	Максимальное количество данных, возвращаемое сервером на fetch-запрос, в байтах	Целочисленное значение	`52428800`
`fetch_min_bytes`	Опциональный	Минимальное количество данных, возвращаемое сервером на fetch-запрос, в байтах	Целочисленное значение	`1`
`fetch_wait_max_ms`	Опциональный	Таймаут ожидания ответа на fetch-запрос, в мс	Целочисленное значение	`500`
`max_poll_records`	Опциональный	Максимальное число записей, возвращаемых на запрос	Целочисленное значение	`500`
`session_timeout_ms`	Опциональный	Таймаут для обнаружения сбоев при управлении группами Kafka	Целочисленное значение	`10000`
`consumers_count`	Опциональный	Количество потребителей, подключающихся к Kafka-серверу	Целочисленное значение	`1`
`consumer_streams`	Опциональный (deprecated)	Размер пула потоков потребителей. Параметр не рекомендован к использованию	Целочисленное значение	`10`
`ssl_keystore_path`	Опциональный	Путь до файла хранилища ключей для двусторонней TLS(SSL)-аутентификации. Поддерживаются абсолютный и относительный пути	Строковое значение	—
`ssl_truststore_path`	Опциональный	Путь до файла хранилища доверенных сертификатов для TLS(SSL)-соединения	Строковое значение	—
`ssl_endpoint_algorithm`	Опциональный	Алгоритм идентификации для соединения по TLS(SSL)	Строковое значение	—
`ssl_cipher_suite`	Опциональный	Алгоритм шифрования SSL (IANA название). Несколько шифров разделяются «,»	Текстовое значение	—
`provide_partition_index`	Опциональный	Сохранить в заголовке `kafka.PARTITION` номер партиции сообщения	Булево значение	—
`key_deserializer`	Опциональный	Десериализатор ключей в Kafka	`String`, `ByteArray`	—
`value_deserializer`	Опциональный	Десериализатор значений в Kafka	`String`, `ByteArray`	—
`rs_brokers`	Опциональный (Синхрон)	Список URL брокеров для ответов	Список	—
`rs_client_id`	Опциональный (Синхрон)	Идентификатор клиента для ответов	Строковое значение	—
`rs_request_required_acks`	Опциональный (Синхрон)	Количество подтверждений от брокера	`0`, `1`, `-1`/`all`	`-1`
`rs_batch_size`	Опциональный (Синхрон)	Размер пакета записей на отправку в байтах	Целочисленное значение	`16384`
`rs_buffer_memory_size`	Опциональный (Синхрон)	Объем буфера для сообщений перед отправкой, в байтах	Целочисленное значение	`33554432`
`rs_partition_key`	Опциональный (Синхрон)	Раздел topic для записи. Можно сделать динамическим через HTTP заголовок Kafka-PARTITION_KEY	Целочисленное значение	—
`rs_linger_ms`	Опциональный (Синхрон)	Задержка группировки сообщений перед отправкой	Целочисленное значение	`0`
`rs_request_timeout_ms`	Опциональный (Синхрон)	Таймаут получения request.required.acks, в мс	Целочисленное значение	`305000`
`rs_enable_idempotence`	Опциональный (Синхрон)	Включение идемпотентности	Булево значение	`false`
`rs_max_request_size`	Опциональный (Синхрон)	Максимальный размер запроса	Целочисленное значение	`1048576`
`rs_max_block_ms`	Опциональный (Синхрон)	Ограничение на время получения метаданных, в мс	Целочисленное значение	`60000`
`rs_retries`	Опциональный (Синхрон)	Количество попыток повторной отправки после ошибки	Целочисленное значение	`0`
`rs_ssl_keystore_path`	Опциональный (Синхрон)	Путь до файла хранилища ключей для ответов	Строковое значение	—
`rs_ssl_truststore_path`	Опциональный (Синхрон)	Путь до файла хранилища доверенных сертификатов для ответов	Строковое значение	—
`rs_ssl_endpoint_algorithm`	Опциональный (Синхрон)	Алгоритм идентификации для TLS(SSL) соединения ответов	Строковое значение	—

kafka_usock - to#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`service_id`	Обязательный	Id сервиса для подключения к серверу unix socket	Строковое значение	—
`service_type`	Обязательный	Тип сервиса для подключения к серверу unix socket	Строковое значение (например, `service_http_proxy`)	—
`headers_whitelist`	Опциональный	Список разрешенных заголовков. Имеет больший приоритет, чем `headers_blacklist`	Список	—
`headers_blacklist`	Опциональный	Список запрещенных заголовков	Список	—
`content_type`	Опциональный	Тип содержимого запроса	Строковое значение	—
`wait_response`	Опциональный	Ожидание http ответа для подтверждения доставки. Не может быть использован при upstream http сервис	Булево значение	`true`
`url`	Опциональный	Url запроса	Текстовое значение	`/`

Пример асинхронного сервиса:

service_sowa_ipa:
  - id: async_kafka_usock
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    kafka_usock:
      from:
        auto_commit: true
        auto_commit_interval: 10000
        auto_offset_reset: latest
        brokers:
          - 10.x.x.x:9092
        client_id: consumerClient
        fetch_max_bytes: 1488
        group_id: group1
        topics:
          - AsyncKafkaUsockTopic
      to:
        service_id: async_kafka_usock_socket_http
        service_type: service_http_proxy

Пример синхронного сервиса:

service_sowa_ipa:
  - id: sync_kafka_usock
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    kafka_usock:
      from:
        auto_commit: true
        auto_commit_interval: 10000
        auto_offset_reset: latest
        brokers:
          - 10.x.x.x:9092
        client_id: consumerClient
        fetch_max_bytes: 1488
        group_id: group1
        rs_brokers:
          - 10.x.x.x:9092
        rs_topic: SyncKafkaUsockRsTopic
        topics:
          - SyncKafkaUsockRqTopic
      to:
        service_id: sync_kafka_usock_socket_http
        service_type: service_http_proxy

SowaIpa - mq_usock#

Группа параметров mq_usock отвечает за взаимодействие по направлению MQ → unix socket.

Внимание! При соединении с service_http_proxy для стабильной работы необходимо задавать:

modifiers:
  set_header:
    - Host IPA

mq_usock - from#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`rq_queue`	Обязательный (если не задан `rq_topic`)	Имя очереди	Строковое значение	—
`rq_name`	Обязательный	Имя MQ менеджера	Строковое значение	—
`rq_hostname`	Обязательный	Хост MQ соединения	IPv4 адрес или псевдоним сервера	—
`rq_port`	Обязательный	Порт MQ соединения	Целочисленное значение (1-65535)	—
`rq_channel`	Обязательный	Канал соединения	Строковое значение	—
`rq_topic`	Обязательный (если не задан `rq_queue`)	Имя topic, соотносится с параметром MQ TOPICOBJ	Строковое значение	—
`rq_user_id`	Опциональный	Имя пользователя для авторизации (пароль должен быть в файле паролей)	Строковое значение	—
`rq_ssl_cert_store`	Опциональный	Путь до хранилища TLS(SSL) сертификатов. Поддерживаются абсолютный и относительный пути	Строковое значение	—
`rq_ssl_cipher_suite`	Опциональный	Спецификатор алгоритма шифрования TLS(SSL)	Строковое значение из списка	—
`rq_reconnect_delay`	Опциональный	Интервал реконнекта к очереди (заменяет deprecated `rq_poll_delay`)	Целочисленное значение	`500мс`
`rq_threads`	Опциональный	Количество потоков для чтения из очереди MQ (после версии 80919)	Целочисленное значение	`5`
`rq_reconnect_on_startup`	Опциональный	Флаг переподключения к MQ менеджеру для восстановления работоспособности	Булево значение	`false`
`rq_topic_string`	Опциональный	Идентификатор topic, соотносится с параметром MQ TOPICSTR	Строковое значение	—
`rq_subscription_name`	Опциональный	Имя подписки, соотносится с параметром MQ SUBNAME	Строковое значение	—
`rq_topic_durability`	Опциональный	Опция MQSO_DURABLE/MQSO_NON_DURABLE при подписке	Булево значение	—
`rq_rfh_routing_header`	Опциональный	Имя заголовка для маршрутизации запроса (имя сервиса)	Строковое значение	—
`rq_alternate_user_id`	Опциональный	Параметр для ALTERNATE_USER_AUTHORITY	Строковое значение	—
`rs_queue`	Опциональный (Синхрон)	Имя очереди ответов	Строковое значение	—
`rs_name`	Опциональный (Синхрон)	Имя MQ менеджера ответов	Строковое значение	—
`rs_hostname`	Опциональный (Синхрон)	Хост MQ соединения ответов	IPv4 адрес или псевдоним	—
`rs_port`	Опциональный (Синхрон)	Порт MQ соединения ответов	Целочисленное значение (1-65535)	—
`rs_channel`	Опциональный (Синхрон)	Канал соединения ответов	Строковое значение	—
`rs_topic`	Опциональный (Синхрон)	Имя topic ответов, соотносится с MQ TOPICOBJ	Строковое значение	—
`rs_topic_string`	Опциональный (Синхрон)	Идентификатор topic ответов, соотносится с MQ TOPICSTR	Строковое значение	—
`rs_subscription_name`	Опциональный (Синхрон)	Имя подписки ответов, соотносится с MQ SUBNAME	Строковое значение	—
`rs_alternate_user_id`	Опциональный (Синхрон)	Параметр для ALTERNATE_USER_AUTHORITY ответов	Строковое значение	—
`rs_user_id`	Опциональный (Синхрон)	Имя пользователя для авторизации ответов	Строковое значение	—
`rs_payload_charset`	Опциональный (Синхрон)	Чарсет тела при записи сообщения в очередь ответов	Строковое значение	—
`rs_ssl_cert_store`	Опциональный (Синхрон)	Путь до хранилища TLS(SSL) сертификатов ответов	Строковое значение	—
`rs_ssl_cipher_suite`	Опциональный (Синхрон)	Спецификатор алгоритма шифрования TLS(SSL) ответов	Строковое значение из списка	—

mq_usock - to#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`route_id`	Обязательный	Идентификатор unix socket маршрута. Возможность маршрутизации по заголовкам ServiceName и ServiceVersion. Значение «*» — без заголовков	Уникальное строковое значение	—
`service_id`	Обязательный	ID сервиса для подключения к серверу unix socket	Строковое значение	—
`service_type`	Обязательный	Тип сервиса для подключения к серверу unix socket	Строковое значение (например, `service_http_proxy`)	—
`headers_whitelist`	Опциональный	Список разрешенных заголовков	Список	—
`headers_blacklist`	Опциональный	Список запрещенных заголовков	Список	—
`content_type`	Опциональный	Тип содержимого запроса	Строковое значение	—
`proxy_rfh2_folders`	Опциональный	Список проксируемых MQ папок. Используется, если `rq_pass_http_headers` не задан	Последовательность текстовых значений	`usr`

Пример асинхронного сервиса:

service_sowa_ipa:
  - id: async_mq_usock
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    mq_usock:
      from:
        rq_channel: SVRCONN.SSL
        rq_hostname: 10.x.x.x
        rq_name: DEV.1.QMGR
        rq_port: 1415
        rq_queue: USOCK.ASYNC.FROM
        rq_reconnect_on_startup: true
        rq_ssl_cert_store: client_ipa.jks
        rq_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
      to:
        - route_id: '*'
          service_id: async_mq_usock_socket_http
          service_type: service_http_proxy
        - route_id: test
          service_id: async_mq_usock_socket_http_test
          service_type: service_http_proxy

Пример синхронного сервиса:

service_sowa_ipa:
  - id: sync_mq_usock
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    mq_usock:
      from:
        rq_channel: SVRCONN.SSL
        rq_hostname: 10.x.x.x
        rq_name: DEV.1.QMGR
        rq_port: 1415
        rq_queue: MQ.SYNC.FROM
        rq_reconnect_on_startup: true
        rq_ssl_cert_store: client_ipa.jks
        rq_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
        rs_channel: SVRCONN.SSL
        rs_hostname: 10.x.x.x
        rs_name: DEV.1.QMGR
        rs_port: 1415
        rs_queue: MQ.SYNC.TO
        rs_ssl_cert_store: client_ipa.jks
        rs_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
      to:
        - route_id: '*'
          service_id: sync_mq_usock_socket_http
          service_type: service_http_proxy
        - route_id: test
          service_id: sync_mq_usock_socket_http_test
          service_type: service_http_proxy

SowaIpa - usock_kafka#

Группа параметров usock_kafka отвечает за взаимодействие по направлению unix socket→Kafka.

Внимание! При соединении с service_http_proxy для стабильной работы необходимо задавать:

modifiers:
  set_header:
    - Host IPA

Для записи в topic пары ключ-значение, ключ необходимо передавать в HTTP заголовке Kafka-KEY.

usock_kafka - from#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`usock_socket_timeout`	Обязательный	Время ожидания ответа в сокет, мс	Целочисленное значение	—
`usock_busy_timeout`	Обязательный	Время ожидания в случае занятого сервера, мс	Целочисленное значение	—
`usock_max_concurrent_connections`	Обязательный	Количество коннектов к серверному сокету	Целочисленное значение	—

usock_kafka - to#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`brokers`	Обязательный	Список URL брокеров	Список	—
`topic`	Обязательный	Тема, в которую производится запись	Строковое значение	—
`client_id`	Опциональный	Идентификатор клиента для журналирования, отслеживания и квот	Строковое значение	—
`request_required_acks`	Опциональный	Количество подтверждений от брокера	`0`, `1`, `-1`/`all`	`-1`
`batch_size`	Опциональный	Размер пакета записей на отправку в байтах	Целочисленное значение	`16384`
`buffer_memory_size`	Опциональный	Объем буфера для сообщений перед отправкой, в байтах	Целочисленное значение	`33554432`
`partition_key`	Опциональный	Раздел topic для записи. Динамическое значение через HTTP заголовок Kafka-PARTITION_KEY	Целочисленное значение	—
`linger_ms`	Опциональный	Задержка группировки сообщений перед отправкой	Целочисленное значение	`0`
`request_timeout_ms`	Опциональный	Таймаут получения request.required.acks, в мс	Целочисленное значение	`305000`
`enable_idempotence`	Опциональный	Включение идемпотентности	Булево значение	`false`
`max_request_size`	Опциональный	Максимальный размер запроса	Целочисленное значение	`1048576`
`max_block_ms`	Опциональный	Ограничение на время получения метаданных, в мс	Целочисленное значение	`60000`
`retries`	Опциональный	Количество попыток повторной отправки после ошибки	Целочисленное значение	`0`
`ssl_keystore_path`	Опциональный	Путь до файла хранилища ключей для двусторонней TLS(SSL)-аутентификации	Строковое значение	—
`ssl_truststore_path`	Опциональный	Путь до файла хранилища доверенных сертификатов	Строковое значение	—
`ssl_endpoint_algorithm`	Опциональный	Алгоритм идентификации для TLS(SSL)	Строковое значение	—
`ssl_cipher_suite`	Опциональный	Алгоритм шифрования SSL	Текстовое значение	—
`headers_whitelist`	Опциональный	Список разрешенных заголовков. Имеет приоритет над `headers_blacklist`	Список	—
`headers_blacklist`	Опциональный	Список запрещенных заголовков	Список	—
`key_serializer`	Опциональный	Сериализатор ключей в Kafka	`String`, `ByteArray`	—
`value_serializer`	Опциональный	Сериализатор значений в Kafka	`String`, `ByteArray`	—
`rs_brokers`	Опциональный (Синхрон)	Список URL брокеров для ответов	Список	—
`rs_client_id`	Опциональный (Синхрон)	Идентификатор клиента для ответов	Строковое значение	—
`rs_group_id`	Опциональный (Синхрон)	Группа потребителей для ответов	Строковое значение	—
`rs_fetch_max_bytes`	Опциональный (Синхрон)	Максимальное количество данных на fetch-запрос, в байтах	Целочисленное значение	`52428800`
`rs_fetch_min_bytes`	Опциональный (Синхрон)	Минимальное количество данных на fetch-запрос, в байтах	Целочисленное значение	`1`
`rs_fetch_wait_max_ms`	Опциональный (Синхрон)	Таймаут ожидания ответа на fetch-запрос, в мс	Целочисленное значение	`500`
`rs_max_poll_records`	Опциональный (Синхрон)	Максимальное число записей на запрос	Целочисленное значение	`500`
`rs_session_timeout_ms`	Опциональный (Синхрон)	Таймаут для обнаружения сбоев при управлении группами	Целочисленное значение	`10000`
`rs_topic`	Опциональный (Синхрон)	Тема, из которой принимается ответ	Строковое значение	—
`rs_timeout`	Опциональный (Синхрон)	Таймаут получения ответа в мс. Не влияет на параметры http_proxy	Целочисленное значение	`10000`
`rs_ssl_keystore_path`	Опциональный (Синхрон)	Путь до файла хранилища ключей для ответов	Строковое значение	—
`rs_ssl_truststore_path`	Опциональный (Синхрон)	Путь до файла хранилища доверенных сертификатов для ответов	Строковое значение	—
`rs_ssl_endpoint_algorithm`	Опциональный (Синхрон)	Алгоритм идентификации для TLS(SSL) ответов	Строковое значение	—
`rs_provide_partition_index`	Опциональный (Синхрон)	Сохранить в заголовке `kafka.PARTITION` номер партиции. Используется при `rs_brokers`	Булево значение	—
`rs_ssl_cipher_suite`	Опциональный (Синхрон)	Алгоритм шифрования SSL для ответов	Текстовое значение	—

Пример асинхронного сервиса:

service_sowa_ipa:
  - id: async_usock_kafka
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    usock_kafka:
      from:
        usock_busy_timeout: 100
        usock_max_concurrent_connections: 10
        usock_socket_timeout: 100
      to:
        batch_size: 1489
        brokers:
          - 10.x.x.x:9092
        buffer_memory_size: 8512
        client_id: producerClient
        request_required_acks: all
        topic: AsyncUsockKafkaTopic

Пример синхронного сервиса:

service_sowa_ipa:
  - id: sync_usock_kafka
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    usock_kafka:
      from:
        usock_busy_timeout: 100
        usock_max_concurrent_connections: 10
        usock_socket_timeout: 100
      to:
        batch_size: 1489
        brokers:
          - 10.x.x.x:9092
        topic: SyncUsockKafkaTopic
        buffer_memory_size: 8512
        client_id: producerClient
        request_required_acks: all
        rs_brokers:
          - 10.x.x.x:9092
        rs_group_id: ll
        rs_timeout: 120000
        rs_topic: SyncUsockKafkaRsTopic

SowaIpa - usock_mq#

Группа параметров usock_mq отвечает за взаимодействие по направлению unix socket→MQ.

Внимание! При соединении с service_http_proxy для стабильной работы необходимо задавать:

modifiers:
  set_header:
    - Host IPA

usock_mq - from#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`usock_socket_timeout`	Обязательный	Время ожидания ответа в сокет, мс	Целочисленное значение	—
`usock_busy_timeout`	Обязательный	Время ожидания в случае занятого сервера, мс	Целочисленное значение	—
`usock_max_concurrent_connections`	Обязательный	Количество коннектов к серверному сокету	Целочисленное значение	—

usock_mq - to#

Название	Обязательность	Описание	Возможные значения	Значение по умолчанию
`route_id`	Обязательный	Идентификатор MQ роута. Используется для маршрутизации внутри адаптера. «*» — пустой контекст	Уникальное строковое значение	—
`rq_topic`	Обязательный (если не задан `rq_queue`)	Идентификатор topic	Строковое значение	—
`rq_queue`	Обязательный (если не задан `rq_topic`)	Имя очереди	Строковое значение	—
`rq_name`	Обязательный	Имя MQ менеджера. «*» для подключения к кластеру	Строковое значение	—
`rq_hostname`	Обязательный	Хост MQ соединения	IPv4 адрес или псевдоним	—
`rq_port`	Обязательный	Порт MQ соединения	Целочисленное значение (1-65535)	—
`rq_channel`	Обязательный	Канал соединения	Строковое значение	—
`rq_user_id`	Опциональный	Имя пользователя для авторизации	Строковое значение	—
`headers_whitelist`	Опциональный	Список разрешенных заголовков	Список	—
`headers_blacklist`	Опциональный	Список запрещенных заголовков	Список	—
`rq_ssl_cert_store`	Опциональный	Путь до хранилища TLS(SSL) сертификатов	Строковое значение	—
`rq_ssl_cipher_suite`	Опциональный	Спецификатор алгоритма шифрования TLS(SSL)	Строковое значение из списка	—
`rq_payload_charset`	Опциональный	Чарсет тела при записи сообщения в очередь	Строковое значение	—
`rq_pass_http_headers`	Опциональный	Записывать ли заголовки в rfh2 usr. Используется, если `proxy_rfh2_folders` не задан	Булево значение	—
`proxy_rfh2_folders`	Опциональный	Список проксируемых MQ папок. Используется, если `rq_pass_http_headers` не задан	Последовательность текстовых значений	`usr`
`rq_use_string_format_for_rfh2`	Опциональный	Формат строки для rfh2	—	—
`rq_jms_type`	Опциональный	JMS тип тела сообщения (byte/text)	Строковое значение	`byte`
`rq_managers_count`	Опциональный	Количество подключений к менеджеру для записи. Влияет на пропускную способность	Целочисленное значение (1-100)	`1`
`rq_queue_access_count`	Опциональный	Количество активных открытий очереди для записи. Влияет на пропускную способность	Целочисленное значение (1-100)	`1`
`main_configuration_reconnect_period`	Опциональный	Время переподключения к основному менеджеру при использовании резервного, в мс	Целочисленное значение (1-65535)	`10000`
`queue_access_timeout`	Опциональный	Таймаут попытки открытия очереди на чтение/запись, в мс	Целочисленное значение (1-65535)	`10000`
`rq_mqgroup`	Опциональный	Группа дополнительных MQ-настроек для резервных подключений	Список параметров (rq_topic, rq_queue, rq_name, rq_hostname, rq_port, rq_channel, rq_user_id, rq_ssl_cert_store, rq_ssl_cipher_suite, rq_payload_charset, rq_jms_type)	—
`rs_queue`	Опциональный (Синхрон)	Имя очереди ответов. Необходим, если ожидание ответа и rs_topic отсутствует	Строковое значение	—
`rs_name`	Опциональный (Синхрон)	Имя MQ менеджера ответов	Строковое значение	—
`rs_hostname`	Опциональный (Синхрон)	Хост MQ соединения ответов	IPv4 адрес или псевдоним	—
`rs_port`	Опциональный (Синхрон)	Порт MQ соединения ответов	Целочисленное значение (1-65535)	—
`rs_channel`	Опциональный (Синхрон)	Канал соединения ответов	Строковое значение	—
`rs_user_id`	Опциональный (Синхрон)	Имя пользователя для авторизации ответов	Строковое значение	—
`rs_ssl_cert_store`	Опциональный (Синхрон)	Путь до хранилища TLS(SSL) сертификатов ответов	Строковое значение	—
`rs_ssl_cipher_suite`	Опциональный (Синхрон)	Спецификатор алгоритма шифрования TLS(SSL) ответов	Строковое значение из списка	—
`rs_timeout`	Опциональный (Синхрон)	Таймаут ожидания ответа по каналу	Целочисленное значение (0-1e7)	—
`rs_mqgroup`	Опциональный (Синхрон)	Группа дополнительных MQ-настроек для резервных подключений ответов	Список параметров (rs_topic, rs_queue, rs_name, rs_hostname, rs_port, rs_channel, rs_user_id, rs_ssl_cert_store, rs_ssl_cipher_suite, rs_timeout)	—

Пример асинхронного сервиса:

service_sowa_ipa:
  - id: async_usock_mq
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    usock_mq:
      from:
        usock_busy_timeout: 100
        usock_max_concurrent_connections: 10
        usock_socket_timeout: 100
      to:
        - route_id: '*'
          rq_channel: SVRCONN.SSL
          rq_hostname: 10.x.x.x
          rq_name: DEV.1.QMGR
          rq_port: 1415
          rq_queue: USOCK.ASYNC.TO
          rq_ssl_cert_store: client_ipa.jks
          rq_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
        - route_id: test
          rq_channel: SVRCONN.SSL
          rq_hostname: 10.x.x.x
          rq_name: DEV.1.QMGR
          rq_port: 1415
          rq_queue: USOCK.ASYNC.TO.TEST
          rq_ssl_cert_store: client_ipa.jks
          rq_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256

Пример синхронного сервиса:

service_sowa_ipa:
  - id: sync_usock_mq
    common:
      logging_package_org_apache_camel: DEBUG
      logging_package_org_springframework: DEBUG
      logging_package_ru_sbt: DEBUG
      passwords_path: passwords_ipa.properties
    usock_mq:
      from:
        usock_busy_timeout: 100
        usock_max_concurrent_connections: 10
        usock_socket_timeout: 100
      to:
        - route_id: '*'
          rq_channel: SVRCONN.SSL
          rq_hostname: 10.x.x.x
          rq_mqgroup:
            - rq_channel: SVRCONN.SSL
              rq_hostname: 10.x.x.x
              rq_name: DEV.2.GMGR
              rq_port: 1416
              rq_queue: USOCK.SYNC.TO
              rq_ssl_cert_store: client_ipa.jks
              rq_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
          rq_name: DEV.1.QMGR
          rq_port: 1415
          rq_queue: USOCK.SYNC.TO
          rq_ssl_cert_store: client_ipa.jks
          rq_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
          rs_channel: SVRCONN.SSL
          rs_hostname: 10.x.x.x
          rs_mqgroup:
            - rs_channel: SVRCONN.SSL
              rs_hostname: 10.x.x.x
              rs_name: DEV.2.GMGR
              rs_port: 1416
              rs_queue: USOCK.SYNC.FROM
              rs_ssl_cert_store: client_ipa.jks
              rs_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
              rs_timeout: 15000
          rs_name: DEV.1.QMGR
          rs_port: 1415
          rs_queue: USOCK.SYNC.FROM
          rs_ssl_cert_store: client_ipa.jks
          rs_ssl_cipher_suite: TLS_RSA_WITH_AES_128_CBC_SHA256
          rs_timeout: 15000