Google Pubsub

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

Компонент Google Pubsub предоставляет доступ к инфраструктуре Cloud Pub/Sub через Google Cloud Java Client для Google Cloud Pub/Sub.

Пользователям Maven необходимо добавить следующую зависимость в свой pom.xml для этого компонента:

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-google-pubsub</artifactId>
    <!-- use the same version as your Camel core version -->
    <version>x.x.x</version>
</dependency>

URI Format

Компонент Google Pubsub использует следующий формат URI:

<span style="color: rgb(0,0,0);">google-pubsub://project-id:destinationName?[options]</span>

Destination Name может быть именем топика или подписки.

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

Ack Mode

AUTO = подтверждение (ack) или отказ (nack) обмена происходит автоматически при завершении. NONE = подтверждение (ack) или отказ (nack) должно быть выполнено явно в последующем процессе.

Возможные значения:
- AUTO
- NONE
По умолчанию: AUTO
Тип: AckMode

Authenticate

Использовать учетные данные при взаимодействии с сервисом PubSub (аутентификация не требуется при использовании эмулятора).
По умолчанию: true
Тип: boolean

Concurrent Consumers

Количество параллельных потоков, потребляющих сообщения из подписки.
По умолчанию: 1
Тип: Integer

Destination Name

Требуется указать имя назначения. Для потребителя это будет имя подписки, а для производителя -- имя темы.
По умолчанию:
Тип: String

Logger Id

Идентификатор логгера, который используется при соответствии с родительским маршрутом.
По умолчанию:
Тип: String

Max Ack Extension Period

Тип: Устанавливает максимальный период продления срока подтверждения сообщения. Значение указывается в секундах.
По умолчанию: 3600
Тип: int

Max Messages Per Poll

Максимальное количество сообщений, получаемых с сервера за один вызов API.
По умолчанию: 1
Тип: Integer

Project Id

Требуется ID проекта Google Cloud PubSub.
По умолчанию:
Тип: String

Service Account Key

Ключ учетной записи службы, который можно использовать в качестве учетных данных для издателя/подписчика PubSub. По умолчанию может загружаться из classpath, но также поддерживаются префиксы classpath:, file: или http: для загрузки ресурса из различных систем.
По умолчанию:
Тип: String

Synchronous Pull

Тип: Синхронная выборка пакетов сообщений.
По умолчанию: false
Тип: 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

Google Mail Stream Google Secret Manager