Я использую EventStore в качестве ReadJournal
и akka-persistence
API для создания постоянного представления.
Проблема, с которой я сталкиваюсь, заключается в том, что я не вижу теги в графическом интерфейсе EventStore после сохранения события. Поэтому я не уверен, сохраняется ли правильное помеченное событие в хранилище событий или нет.
Перейдя по http://pkaczor.blogspot.in/2015/12/akka-ddd-integrating-eventstore.html и небольшой тест, я вижу, что не могу читать события, сохраняемые тегами в хранилище событий, через currentEventsByTag
API сохраняемости akka.
Мой адаптер событий записи упоминается ниже.
public class ViewEventAdapter implements WriteEventAdapter {
@Override
public String manifest(Object event) {
return "";
}
@Override
public Object toJournal(Object event) {
if (event instanceof DomainEvent) {
DomainEvent domainEvent = (DomainEvent) event;
return tagged(domainEvent , "ViewRelated");
}
return event;
}
private Tagged tagged(Object event, String tag) {
Set<String> tags = new HashSet<String>();
tags.add(tag);
return new Tagged(event, tags);
}
}
Ниже приведена конфигурация.
akka.persistence {
journal {
plugin = "eventstore.persistence.journal"
event-adapters {
tagger = "com.wt.domain.write.events.ViewEventAdapter"
}
event-adapter-bindings {
"com.wt.domain.write.events.DomainEvent" = tagger
}
}
}
И, наконец, соответствующий фрагмент кода, в котором я сохраняю eventByTag.
private void handle(DomainEvent event) {
ViewEventAdapter viewAdapter = new ViewEventAdapter();
persist(viewAdapter.toJournal(event), evt -> {
domainObject.update(evt);
sender().tell("Done"), self());
});
}
}
Любая помощь в этом вопросе очень ценится.
Здесь есть еще один вопрос в аналогичных строках: #47286703">Почему Akka Persisence Query Read Journal не извлекает мои события?