AVRO RPC

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

Этот компонент обеспечивает поддержку RPC протокола Apache Avro, предоставляя производителя и потребителя для использования Avro через Netty или HTTP.

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

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

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

Host

• Обязательно Имя хоста для использования.

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

• Тип: String

• Тип: Message Name

• Название сообщения для отправки.

• String

Port

• Обязательно Укажите номер порта для подключения.

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

• Тип: int

• Тип: Protocol

• Протокол Avro для использования.

• Protocol

Protocol Class Name

• Протокол Avro для использования, задается через полное имя класса FQN.

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

• Тип: String

• Тип: Protocol Location

• Местоположение протокола Avro protocol.

• String

Reflection Protocol

• Если протокол задан через объект с использованием рефлексии, его следует использовать только с параметром protocol, потому что для protocolClassName тип протокола будет определён автоматически.

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

• Тип: boolean

Single Parameter

• Если установлено значение true, параметр consumer не будет заключен в массив. Произойдёт ошибка, если протокол укажет более одного параметра для сообщения.

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

• Тип: boolean

Transport

• Обязательно Протокол передачи данных, который будет использоваться:

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

  • http

  • netty

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

• Тип: AvroTransport

• Тип: Uri Authority

• Авторизация для использования (username and password).

• String

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