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