Ошибка публикации сообщения из PostgreSQL в RabbitMQ с использованием расширения amqp - сбой входа на брокер 1 - PullRequest
Новая
       14

Ошибка публикации сообщения из PostgreSQL в RabbitMQ с использованием расширения amqp - сбой входа на брокер 1

0 голосов
/ 14 февраля 2019

Я пытаюсь опубликовать сообщение из PostgreSQL в RabbitMQ (оба работают на Docker) 

SELECT amqp.publish(1, 'amqp.direct', 'EMAIL', 'message');

, но возвращает false и предупреждающее сообщение:

ПРЕДУПРЕЖДЕНИЕ:amqp [ my_host_address: my_port ] Не удалось войти в систему на брокерепараметры: согласованный channel_max = 0 (без ограничения) превышает максимально допустимое значение (2047)

Параметры брокера в таблице amqp.broker - определены хост, порт, виртуальный хост, имя пользователя, парольправильно.Можно публиковать сообщения из консоли моего компьютера в RabbitMQ, используя Curl и те же параметры подключения, и они добавляются в очередь сообщений.

1 Ответ

0 голосов
/ 15 февраля 2019

Было два возможных решения:

  1. добавить переменную окружения в стек Portainer RabbitMQ: 
    RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS: '-rabbit channel_max 0'

Исправлено src/librabbitmq/amqp_socket.c

https://github.com/omniti-labs/pg_amqp/issues/23

...