Описание тега akka-persistence
Сохранение Akka позволяет субъектам с отслеживанием состояния сохранять свое внутреннее состояние, чтобы его можно было восстановить при запуске актора, перезапуске после сбоя JVM или супервизором или при миграции в кластере.
1
ответ
Изменить постоянный запрос с устаревшего PersistentView
Я использую Akka Persistence, с LevelDB в качестве плагина для хранения, в приложении, написанном на Scala. На стороне запроса текущая реализация использует PersistentView, который опрашивает сообщения от PersistentActorЖурнал, просто зная идентифик…
15 сен '17 в 12:39
2
ответа
Почему у akka.persistence все еще бета-версия? Это стабильно?
Почему akka.persistence до сих пор выпускается бета-версия для пакетов nuget. Означает ли это, что он все еще нестабилен и не подходит для использования в производственных приложениях?
20 мар '17 в 06:42
1
ответ
События не восстанавливаются в Akka 2.4.0 Persistence & Cassandra Journal Plugin 0.6
Я пытаюсь написать приложение, использующее Akka (версия 2.4.0) Persistency и плагин Cassandra (версия 0.6, https://github.com/krasserm/akka-persistence-cassandra) для восстановления после сбоев. События сохраняются на Кассандре без проблем, однако,…
25 мар '16 в 15:39
0
ответов
Выполнение события akka-persistence-cassandra задерживается из-за пропущенных событий
Как часть кода akka-persistence-cassandra - событие, которое приходит с порядковым номером!= 1, инициирует поиск отсутствующей процедуры в случае, если порядковый номер 1 отсутствует в текущем временном интервале. Поскольку события для одного и того…
05 ноя '18 в 10:02
1
ответ
Акка персистентность и Mongodb: сбой персистентности при воспроизведении событий для persistenceId
Я использую akka-persistence с помощью mongodb с помощью этого плагина https://github.com/ironfish/akka-persistence-mongo/ mongodb. когда я запускаю свой код, я получаю следующую ошибку: [ERROR] [11/19/2016 16:47:29.355] [transaction-system-akka.act…
19 ноя '16 в 11:31
1
ответ
Замена базы данных sql с помощью akka-persistence - почему этого не происходит?
Есть способы заменить базы данных SQL в Haskell, Clojure: http://www.datomic.com/ (Clojure) https://github.com/dmbarbour/haskell-vcache https://hackage.haskell.org/package/acid-state Однако я не могу найти библиотеку для этого в Scala, используя akk…
18 янв '17 в 14:24
1
ответ
AKKA.NET - Очередь и повтор
В рамках изменения нашего приложения с гигантского монолита на микрофон Мы разрабатываем микросервис уведомлений, который может использоваться всеми другими модулями для отправки уведомлений, таких как электронная почта, SMS, push-уведомления и т. Д…
27 дек '16 в 16:58
1
ответ
Стойкость к акке ФСМ
Я использую Akka FSM в своем проекте и собираюсь добавить постоянство. Простое решение состоит в том, чтобы использовать Persistent FSM ( https://doc.akka.io/docs/akka/current/persistence-fsm.html). Однако в официальной документации есть предупрежде…
05 сен '18 в 06:58
0
ответов
События, запускающие другие события - саги / менеджеры процессов практически в Акке
Я создаю CQRS-ориентированную систему, использующую постоянство Akka как побочный проект и учебное упражнение. Я ищу помощь в том, как я это моделирую. Короче, у меня есть игра. Чистая игровая механика - это FSM (я на самом деле использую Persistent…
29 мар '16 в 05:01
2
ответа
Акка-персистентность с Play Framework
Я настроил проект Play Framework и хочу использовать akka-persistence вместе с ним. Я скачал JAR для akka-persistence и поместил его в папку lib моего проекта Play. Классы akka-persistence распознаются, и я могу скомпилировать и запустить приложение…
16 дек '14 в 18:07
1
ответ
Акка рекомендую pratice для инициации `PersistentActor`
case class State(id: Long, remain: Int) { def take(t: Take) = copy(remain = remain - t.amount) } object StateService { def getInitState(id: Long): Future[State] } sealed trait Evt case class Init(id: Long) extends Evt case class Take(id: Long, amoun…
06 апр '16 в 08:36
1
ответ
Акка Упорство Query и актерский осколок
Я делаю запрос стороны приложения актеров CQRS Akka. Актеры запросов настроены как кластерный осколок и заполнены событиями из одного потока постоянных запросов. Мои вопросы: Если один из актеров в кластере перезапускается, как его восстановить? Вык…
04 июл '16 в 18:02
0
ответов
Не в состоянии упорствовать актер
Я хочу, чтобы события в Акке сохранялись только тогда, когда в актере произошел сбой. Я пытаюсь следующий код для достижения постоянства. package persistence import akka.actor._ import akka.persistence._ case class Cmd(data: String) case class Evt(d…
08 ноя '18 в 07:09
1
ответ
Выбор базы данных для вставки данных из кода Scala
У меня есть проект, написанный на Scala, где я хочу сохранить входящие данные в какой-либо базе данных. Мой наставник предложил Постоянство (Акка), но из того, что я прочитал, кажется, что он просто отслеживает состояние, так что прежнее состояние м…
20 апр '18 в 06:42
0
ответов
АККА Актер Менеджмент
Есть ли способ найти актера в системе акторов по идентификатору персистентности, и если он еще не создан, чтобы создать его экземпляр? Я бы ожидал иметь уже реализованный метод или специальный актер, который мог бы получить другой актер ref или созд…
25 июл '18 в 09:10
1
ответ
deliveryId owerflow для гарантии AtLeastOnceDelivery от постоянства akka
Я пытаюсь реализовать декоратор AtLeastOnceDelivery для надежного обмена сообщениями для разных участников. Таким образом, такой декоратор попытается обработать довольно интенсивный обмен сообщениями и поделится циклом lyfecycle с приложением. Согла…
17 июл '17 в 09:46
1
ответ
Как я могу сбросить журнал кассандры между тестами?
Я тестирую систему актера и хотел бы выполнить сброс журнала между тестовыми прогонами.
23 окт '16 в 19:10
1
ответ
Как использовать в тестах другой файл application.conf, чем в коде prod?
Я пытаюсь протестировать PersistentActor с самым масштабным, но я не знаю, как указать тестовый код, чтобы использовать что-то вроде application-test.conf вместо application.conf (я хочу изменить хранилище leveldb для событий в хранилище памяти). Ес…
12 апр '17 в 08:13
1
ответ
Найти актера по номеру персистентности
У меня есть система, в которой есть актер на пользователя. Пользователи отправляют сообщения редко, но когда они это делают, они отправляют обычно не одно, а несколько. В настоящее время у меня есть карта, где я храню persistenceId -> ActorRef, К…
07 ноя '18 в 15:12
1
ответ
Akka Persistence Cassandra с Akka 2.3.0, вызывающий роковое EOFException при использовании с Play 2.2.1
Любая идея, почему я получаю следующую ошибку после добавления Akka в мои библиотечные зависимости и выполнения test задача? Uncaught error from thread [reactivemongo-akka.actor.default-dispatcher-4] shutting down JVM since 'akka.jvm-exit-on-fatal-e…
25 мар '14 в 20:32