Потоковый процессор сначала не обработал сообщения правильно, а затем умножил его

Question

У меня есть две темы, которые связаны StreamProcessor:

Тема A -> Процессор A -> Тема B

1. Я отправляю сообщение в первую очередь в Темы a, которое затем записывается там, а затем через Обработчик A обрабатывается и заканчивается в Теме B.

2. Поведение # 1 повторяется, но не на постоянной основе

Есть идеи, что можно сделать, чтобы решить эту проблему?

Заранее спасибо.

Приветствия

Frank

Answer 1

Похоже, это решено.

Проблема заключалась в побочном эффекте, вызванном сохранением локальной переменной в экземпляре класса, что вызывало некоторые странные и совершенно непредсказуемые (инварианты)!