Скажем, у меня есть этот код: private void CreateSnapshots(IEnumerable<StreamHead> streams) { foreach (StreamHead head in streams) { IAggregate aggregate = ???; IMemento memento = aggregate.GetSnapshot(); var...

При настройке постоянства mongodb для EventStore Oliver требуется ли регистрация BsonClassMap для каждого типа событий? Если я этого не сделаю, я получу исключение Unknown discriminator value 'InventoryItemCreated' . Я регистрирую все типы...

Как я узнал в Почему CQRS репозиторий публикует события, а не хранилище событий? публиковать события — задача репозитория CQRS. Все идет нормально. Разумеется, сохранение событий и их публикация должны осуществляться в рамках одной транзакции....

Я вижу следующую ошибку в EventStore Джонатона Оливера: ОШИБКА: 23505: повторяющееся значение ключа нарушает уникальное ограничение "ix_commits_revisions" Есть идеи, почему это происходит?

Может ли кто-нибудь указать мне сериализатор protobuf-net для NEventStore 3.0? У меня проблемы, я думаю, в основном из-за сериализации в хранилище событий 3, заключающей тело события и заголовки в EventMessage. Я не уверен, как правильно...

Насколько я понимаю, CommitId используется внутри хранилища событий Джонатана Оливера. До сих пор я всегда предоставлял Guid.NewGuid() вместо CommitId . Когда бы вы хотели сделать что-то другое? Я не понимаю, почему он выставлен в его...

Мы используем CQRS + ES. ES - это NEventStore (далее JOliver EventStore). У нас есть 2 агрегата в разных командах. Проекции второго AR зависят от данных, записанных первыми проекциями AR в модели чтения. Проблема в том, что когда мы запускаем...

Я прорабатываю базовый пример работы с NEventStore с RavenDB и наткнулся на камень преткновения. Мне удалось успешно зафиксировать свои события в источнике данных RavenDB, но теперь мне нужно вытащить их обратно, чтобы воспроизвести их шаблон (CQRS...

Мой класс команд выглядит следующим образом: public class RegisterToConference : ICommand { public RegisterToConference() { this.Id = Guid.NewGuid(); this.Seats = new Collection<SeatQuantity>();...