Я пытаюсь отправить несколько коллекций на один и тот же входной терминал узла сборщика в моем потоке сообщений, как показано ниже:
Терминал «out1» переходит на входной терминал на Collector, называемый «in1», а «out2» - на входной терминал с именем «env». Мне нужен только один in1 и один env в коллекции вместе. Всего может быть до 7 коллекций.
В ESQL есть цикл FOR, выполняющий итерацию по коллекции и основанный на некоторых критериях, ПРОПАГАТИРОВАТЬ сообщение на in1 и env или нет. Операторы распространения находятся внутри этого цикла FOR.
Это конфигурация узла Colelctor. Количество сообщений установлено на «1» для обоих входных терминалов, поскольку мне нужны только один in1 и один env в коллекции.
Проблема, с которой я сталкиваюсь, заключается в следующем для сценария с двумя коллекциями, которые должны быть созданы:
- Сообщение1 распространяется на out1 / in1
- Сообщение1 распространяется на out2 / env
- Сообщение2 распространяется на out1 / in1
- Вся обработка прекращается. Flow простаивает, вероятно, истекший срок.
- Сообщение2 распространяется на out2 / env.
Похоже, проблема в узле Collector, скорее всего, в настройках конфигурации и в том, как я отправляю сообщения на входные терминалы. Кто-нибудь, кто знаком с использованием узла Collector, видит что-нибудь очевидное, что можно сделать, чтобы исправить №4 выше?
