Как использовать PersistentQueue в реакторе?

Question

Я пытаюсь настроить Reactor на использование настойчивости на основе Chronicle, и я не могу найти информацию об этом в документации. Я вижу два пути:

1. Создать свой собственный диспетчеру поддерживающий PersistentQueue
2. Использование EventBatcher с такой очереди, чтобы обернуть мой Reactor экземпляр

Какой вариант лучше? Или, может быть, есть другое решение, которое я забыл?

Answer 1

Реактор не имеет стойкости, встроенной в объект Reactor (именно поэтому вы не находите документацию на нем :).

Если вы пытаетесь сохранить события, проходящие в целях устойчивости и повтора, вы, вероятно, захотите использовать EventBatcher. У test for EventBatcher есть код, в котором показано, как объединить Observable и PersistentQueue.

Возможность написания собственных PersistentDispatcher, безусловно, интересная. Этот путь будет чреват опасностью, однако, поскольку диспетчерский код неумолимо, когда дело доходит до пропускной способности. Даже самые незначительные изменения могут сильно повлиять на пропускную способность. Мы просто переписали их, чтобы получить больше производительности, поэтому последний код в главном отличается от 1.0 версий Dispatchers.

Я бы не стал рекомендовать брать маршрут Dispatcher. Сначала я попробую EventBatcher, и только если это не может быть использовано в вашем случае использования, я бы экспериментировал с пользовательским Dispatcher. Есть два новых абстрактных базовых класса (here и here), чтобы основывать новые версии Dispatcher, если вы решите пойти по этому маршруту.