Описание тега akka.net-persistence

Вопросы с тегом
0 ответов

Читатель журнала Akka.net пропустил события

В нашем приложении мы используем Akka.net, с источником событий. Постоянные участники сохраняют свои события в базе данных SQL Server. У нас также есть акторы представлений, которые подписываются на эти события, используя запрос чтения журнала / пос…
30 авг '18 в 08:38
1 ответ

Akka.Net: как создавать постоянные взгляды через читателя журнала

Согласно документации Akka.Net, PersistentView устарел, и вместо него следует использовать PersistenceQuery. В приложении ASP.Net Core 2.0 Web-API я использую Akka.Net с источником событий. Я использую плагин SQL Server для постоянства, с событиями …
05 мар '18 в 12:43
2 ответа

Могу ли я читать / писать от отдельных актеров с одинаковым PersistenceId?

Вступление Akka.Persistence в блоге Petabridge проясняет, что у вас не может быть нескольких актеров с одинаковым PersistenceId: PersistenceId поле имеет важное значение - оно однозначно идентифицирует сущность, которая сохраняет свое состояние, ис…
29 авг '16 в 15:49
1 ответ

Десериализовать постоянное сообщение akka.net, используя C#

Я использовал постоянство akka.net для хранения некоторых типов сообщений в базе данных сервера sql. И по этому бизнес-сценарию это работает. В другом случае я просто хотел десериализовать сообщение с помощью C# .net и увидеть свойство сообщения без…
25 апр '17 в 06:59
1 ответ

Акка. Проблемы с сохранением после обновления до 1.3.1.0

Все работало просто отлично.... тогда я решил обновить до AKKA.NET до 1.3.1.0... Получил много проблем и решил их, однако я не могу найти решение этой последней (я надеюсь). Сообщение об ошибке: ---> System.Reflection.TargetInvocationException: искл…
07 сен '17 в 13:58
1 ответ

Ошибка персистентности при воспроизведении событий... System.NotSupportedException: универсальный IDictionary еще не поддерживается

Можете ли вы помочь? При сохранении один или два раза работает нормально. Три или больше, и я получаю это: [INFO][11/28/2017 2:57:27 PM][Thread 0005][[akka://ECHO3DEV/user/api-master/PortfolioCoordinator/TK#425630680]] Portfolio Actor: TK completely…
28 ноя '17 в 15:03
1 ответ

Akka.net: заверение сообщения о тайм-ауте всегда запускается

Представьте, что у вас есть актер, у которого есть "деловой" тайм-аут. Я бы хотел, чтобы этот тайм-аут был запущен, даже если сервер, на котором живет актер, умирает или перезагружается. Я бы создал этого актера как настойчивого. Каков наилучший спо…
01 июн '16 в 17:04
1 ответ

По умолчанию, где Akka.net хранит свои сообщения?

Я скачал пример кода с github и запустил AtLeastOnceDelivery.sln. При каждом новом запуске он отправляет сообщения вместе с ним. И если я изменяю пространство имен сообщения, оно показывает ошибку, начатую с Error loading snapshot [SnapshotMetadata&…
24 сен '18 в 08:17
1 ответ

Akka.Net и в памяти постоянство

Я пытаюсь отвлечься от упорства, и я еще не могу восстановить актера. Мое намерение состоит в том, чтобы получить Actor по его persistenceId (так же, как мы получаем Entity, используя GetById в DDD). Я могу получить ссылку на List и добавить ее в пе…
21 янв '17 в 15:19
2 ответа

Как применить EventBus CQRS с Akka.net и Akka.Persistence

Меня интересует, как применять CQRS и Event Sourcing с Akka.net. Я уже заметил http://getakka.net/docs/Persistence, которое поставляет часть ES. Насколько я понимаю, обработчики команд и AggergateRoot могут быть представлены ReceivePersistentActor в…
28 янв '17 в 18:34
1 ответ

Исключение System.Format при использовании конфигурации Akka.Persistence

Я изо всех сил пытаюсь устранить проблему исключения System.Format, которое возникает в результате анализа моего файла конфигурации Akka.Net. Я знаю, что исключение происходит из блока постоянства конфигурации: persistence{ journal { plugin = "akka.…
16 мар '17 в 13:03
1 ответ

Как проверить akka.net постоянных актеров

Я использую [Akka.Net 1.3.1] смесь ReceiveActors и ReceivePersistentActors, и теперь я хочу написать тесты для моей актерской системы. MyPersistentActor наследуется от ReceivePersistentActor, а MyActor наследуется от ReceiveActor. Я также установил …
04 окт '17 в 14:50
0 ответов

Создать Akka.NET Persistence Actor в ServiceFabric

У меня есть несколько микросервисов, и я использую ServiceFabric (локально), чтобы масштабировать его, они связываются с NServiceBus и RabbitMQ. В одном из микросервисов я использовал akka.net, чтобы воспользоваться преимуществами почтового ящика и …
05 ноя '18 в 05:03
1 ответ

Как создать SHARED LIST для хранения объектов для актера?

Я хочу рассчитать среднее полное время для выбора товара в магазине. Модуль комплектования отправит сообщение с номером времени для завершения и сохранит имя, когда выбор завершен, актеру А. Как и каждый раз, когда он завершает операцию выбора в раз…
27 фев '17 в 06:31
1 ответ

Восстановление актера постоянства Akka.net завершилось неудачно с изменением сообщения с новыми свойствами

Использовал субъект сохранения для сохранения сообщения в базе данных SQL Server. Исходный формат сообщения указан ниже. Система запускалась с этим форматом несколько раз, и многие из этих сообщений были сохранены. В настоящее время я изменил формат…
26 апр '17 в 09:42
1 ответ

Конфигурация персистентности SQL сервера Akka.Net не загружается

Я пытаюсь обновить существующий (демо) проект с Akka.Net 1.0.8 до чего-то более свежего (1.3.2 или чего-то еще). Я застрял при получении постоянства загрузки сервера SQL. Я предпринял следующие шаги: Создан пустой проект и включен пакет Akka.Persist…
21 фев '18 в 10:12
1 ответ

Каков порядок восстановления Акка.

Я прочитал введение в Akka.Persistence в блоге Petabridge и считаю эту часть кода немного запутанной: Recover<string>(str => _msgs.Add(str)); // from the journal Recover<SnapshotOffer>(offer => { var messages = offer.Snapshot as Li…
09 авг '16 в 20:57
0 ответов

Правильный шаблон для сохранения творчества детей-актеров

Каков правильный шаблон для постоянного создания дочернего субъекта (если он не существует) и отправки ему сообщения? Наш подход пока такой, как показано ниже - в идеале мы бы создали дочерний актер внутри этого действия делегата Persist (как показа…
30 сен '18 в 19:22
1 ответ

Почему Akka.Persistance не воспроизводит записи моего журнала

Я пишу реализацию Akka.Persistence for Service Fabric, и мне кажется, что я не могу заставить работать моментальный снимок. Когда он пытается восстановить состояние, он получает последний снимок, но не воспроизводит события с момента последнего сним…
24 июл '16 в 21:37
1 ответ

Как Akka.NET Persistence обрабатывает повторные сообщения, содержащие IActorRef?

Если я посылаю актеру Akka.NET сообщение, являющееся объектом, содержащим IActorRef, и затем сохраняю это сообщение, JSON, записанный в таблицу журнала, выглядит следующим образом: {"$id":"1","$type":"LearningAkka.Program+BindReference, LearningAkka…
27 май '17 в 21:09