У меня есть только один запущенный экземпляр микроинтегратора WSO2, в котором у меня есть хранилище сообщений JDBC и процессор пересылки запланированных сообщений, прослушивающий новые сообщения в хранилище сообщений.
Теперь, когда я увеличиваю количество задач (количество участников) обработчика сообщений до 2 или более. Сообщение, хранящееся в процессоре сообщений, обрабатывается всеми задачами. Как мне этого избежать. Я хочу, чтобы только одна из задач обработки сообщений приняла мое сообщение.
Да.. Я запросил сообщения в хранилище сообщений перед активацией обработчика сообщений, и там только один.. но в тот момент, когда я его активирую.. Я вижу два вызова конечной точки.. версия микроинтегратора 1.2.0
Точно такая же проблема в EI 6.5.0. Просмотр исходного кода хранилища сообщений JDBC показывает, что нет мер, препятствующих одновременному чтению и удалению одних и тех же записей в таблице хранилища сообщений несколькими задачами обработки сообщений.
Да, я тоже проверил.. Похоже, что нет обработки..
Просто чтобы уточнить, заметили ли вы, что одно сообщение в хранилище сообщений обрабатывается всеми процессорами сообщений. Какую версию микроинтегратора вы используете в своей среде.