Shovel плагин для объединения сообщений от 2 vhosts в 1 vhost

Я работаю над решением, используя плагин лопатой.

Цель состоит в том, чтобы все сообщения, которые отправляются Vhost1(vh1POC)/Queue1 а также vhost2(vh2POC)/Queue2 должны агрегироваться на vhost3(vh3POC)/Queue3 и быть услышанным mulesoft Применение (адаптер)

Я использовал следующие скрипты в rabbitmqctl (command line) но может кто-нибудь, пожалуйста, помогите мне объединить это в одном скрипте вместо создания двух экземпляров:

1.

rabbitmqctl set_parameter -p vh1POC shovel shovel1demoPOC "{\"src-protocol\": \"amqp091\", \"src-uri\":\"amqp://userName:Password@localhost/vh1POC\", \"src-queue\": \"q.vh1poc\",\"dest-protocol\": \"amqp091\", \"dest-uri\": \"amqp://userName:Password@localhost/vh3POC\",\"dest-queue\": \"vh3poc.q\"}"-->
  • Исходный URI - amqp: // имя пользователя: пароль @localhost/vh1POC
  • Исходная очередь - q.vh1poc
  • Исходный протокол - amqp091
  • URI назначения - amqp: // имя пользователя: пароль @localhost/vh3POC
  • Очередь назначения - vh3poc.q
  • Протокол назначения - amqp091

2.

rabbitmqctl set_parameter -p vh2POC shovel shovel2POC "{\"src-protocol\": \"amqp091\", \"src-uri\":\"amqp://userName:Password@localhost/vh2POC\", \"src-queue\": \"q.vh2poc\",\"dest-protocol\": \"amqp091\", \"dest-uri\": \"amqp://userName:Password@localhost/vh3POC\",\"dest-queue\": \"vh3poc.q\"}"-->
  • Исходный URI - amqp: // имя пользователя: пароль @localhost/vh2POC
  • Исходная очередь - q.vh2poc
  • Исходный протокол - amqp091
  • URI назначения - amqp: // имя пользователя: пароль @localhost/vh3POC
  • Очередь назначения - vh3poc.q
  • Протокол назначения - amqp091

0 ответов

Другие вопросы по тегам