Поддержка EventsByTag в EventStore

Я использую 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 не извлекает мои события?


person smartinsert    schedule 14.11.2017    source источник
comment
Они есть в метаданных?   -  person Piotr Kula    schedule 12.07.2018