Добрый день, коллеги программисты
Снова обращаюсь к вам за помощью. Не могу понять, как правильно работать с нодой Collector. Имеем проект, картинка которого предоставлена ниже.
Необходимо параллельно обновить 2 базы и по окончании апдейта обеих отправить сообщение в служебную очередь. Но, если после ноды коллектор произойдет эксепшен, то не делается ролбек в базах. Более того, сообщение просто зацикливается в той конструкции которую я нарисовал.
Подскажите:
Почему при возникновении ошибки после ноды Collector поток не откатывается и не происходит перехват ошибки на уровне ноды MQ Input? Если поставить обработчик ошибок на терминал Catch ноды Collector, то опять же не делается ролбек. Как мне его получить?


При таймауте в ноде Collector происходит тоже самое – ролбека нет


Почему происходит зацикливание? В моем случае я принудительно делаю в ноде Process исключение (для тестов) И теперь сообщение постоянно бегает между нодами Collector и Process.

Поток в дебагере:

Да, действительно... не заметил этот абзац. Это немного усложнит мою задачу:(