Настройка ActiveMQ адаптера

Обзор

ActiveMQ адаптер Accelera Flows - это модуль для получения и обработки сообщений из очереди ActiveMQ.

Формат сообщения - JSON. Пример:

{
  "id": "987654321",
  "event": "transaction",
  "flowId": "",
  "context": {
   	"TRANSACTION_DATE": "21-01-2021 11:36:30",
		"ACCOUNT_NUMBER": "123456789",
		"MERCHANT_CITY": "London",
		"MERCHANT_COUNTRY": "UK",
		"MERCHANT_CATEGORY": "5699",
		"TRANSACTION_ID": "123456789"
	  }
}

id - идентификатор клиента для сценария.
event - название события.
flowId - (опционально) идентификатор сценария, в который нужно отправить события. Может быть пустым, тогда событие уйдет во все сценарии.
context - параметры контекста события, которые будут отправлены в сценарий. Может быть пустым объектом - {}

Конфигурация

Распакуйте образы приложения из файла flows_activemq_adapter_{your_version}.tar.gz следующей командой:

docker load < flows_activemq_adapter_{your_version}.tar.gz

Создайте файл docker-compose.yaml со следующим содержимым:

version: '3'
services:
  activemq_adapter:
    image: devcubesolutions/flows_activemq_adapter:latest
    container_name: activemq_adapter
    restart: unless-stopped    environment:
      - NODE_ENV=production
      - BROKER_CONNECTION=amqp://user:password@broker_host:5672
      - ACTIVE_MQ_HOST=127.0.0.1
      - ACTIVE_MQ_PORT=61613
      - ACTIVE_MQ_USER=user
      - ACTIVE_MQ_PASSWORD=password
      - ENDPOINT=triggers
      - ENCODING=utf8

Описание параметров

image

Имя образа, который был распакован на предыдущем шаге, можно узнать командой docker images

container_name

Имя контейнера при запуске, рекомендуется оставить без изменения

restart

Политика рестарта процесса при остановке или ошибке, по умолчанию 'unless-stopped'

Environment

BROKER_CONNECTION - адрес подключения к RabbitMQ.

ACTIVE_MQ_HOST - Хост ActiveMQ брокера

ACTIVE_MQ_PORT - Порт ActiveMQ брокера

ACTIVE_MQ_USER - Имя пользователя ActiveMQ брокера

ACTIVE_MQ_PASSWORD - Пароль ActiveMQ брокера

ENDPOINT - Имя очереди или топика с потоком событий.

ENCODING - Кодировка сообщения, по умолчанию - utf8.

Запуск

Для запуска адаптера используйте следующую команду:

docker-compose -f {путь к вашему docker-compose файлу} up

Получить доступ к логам и проверить работоспособность адаптера можно командой

docker logs -f activemq_adapter

Остановка

Для остановки адаптера используйте команду:

docker-compose -f {путь к вашему docker-compose файлу} down