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