Удаление сообщений из постоянного журнала Akka

Я тестирую постоянного актера Akka. Для этого я использую сохраняемость в памяти. Тест начинается, и я вижу, как актер восстанавливает сохраненные сообщения. Я пробую следующее:

Я отправляю актору сообщение, которое запускает deleteMessages(LastMessage). Я надеялся, что это сообщение приведет к очистке журнала. Актер, похоже, не обрабатывает это сообщение, поскольку восстанавливаемые сообщения ранее столкнулись с исключением. Таким образом, он генерирует исключение и не приступает к обработке сообщения.

Как я могу очистить сохраненный журнал?

Я также думал, что сохраняемость в памяти не восстанавливает предыдущие тестовые сообщения из журнала.


scala akka-persistence
person Gakuo    schedule 07.03.2019    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Для более эффективной реализации журнала в памяти для использования в тестах я бы рекомендовал использовать https://github.com/dnvriend/akka-persistence-inmemory.

Он поддерживает очистку журнала (и снимков): https://github.com/dnvriend/akka-persistence-inmemory#clearing-journal-and-snapshot-messages, а также ReadJournal.

person Frederic A.    schedule 07.03.2019