Можно ли обработчику-тейлеру SingleChronicleQueue добавить другое сообщение в одну и ту же очередь? - PullRequest
Новая
       15

Можно ли обработчику-тейлеру SingleChronicleQueue добавить другое сообщение в одну и ту же очередь?

0 голосов
/ 09 ноября 2018

У меня есть 1 SingleChronicleQueue, к которому добавляются различные сообщения через прокси-API methodWriter.

Мой обработчик читателя обрабатывает сообщение «message1» и добавляет к другому обработчику сообщение «message2», чтобы тот же обработчик обработал его другим методом (message2 ()). 

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

Или тейлеры всегда должны писать в другую очередь 'Out' и иметь это промежуточное положение?

Причина такого подхода к управлению неблокирующим доступом к общему состоянию.

1 Ответ

0 голосов
/ 09 ноября 2018

Самое простое решение - иметь одну очередь для всех ваших событий и заставить читателей игнорировать события, которые им не нужны.

Могут быть веские причины, чтобы иметь больше очередей, однако я бы начал с одной и продолжил свой путь оттуда.

ПРИМЕЧАНИЕ. С одной очередью трейлер будет видеть все сообщения, даже те, которые написал тейлер.

...