У меня есть 1 SingleChronicleQueue
, к которому добавлены разные сообщения через прокси-API methodWriter.
Мой обработчик чтения обрабатывает «сообщение1» и добавляет обратно другое сообщение «сообщение2», чтобы тот же обработчик обрабатывал его другим методом (сообщение2()).
Flow is:
Append: proxy appends message1 to Q
Tailer: handler1 reads message1 and
appends using proxy message2 to same Q
Tailer: handler1 reads message2
OK?
Или трейнеры всегда должны писать в другую очередь «Исходящие», а она должна находиться между ними?
Причина такого подхода к управлению неблокирующим доступом к общему состоянию.