Мой метод хранилища реактивен: < /p>
Uni add(Aggregate aggregate);
< /code>
и мой уровень сервиса выглядит так: < /p>
var result = currencyCommandRepository.add(currency)
.invoke(item -> logger.infof("Currency persisted: %s", item.getId().getValue()))
.call(item -> domainCacheService.put(Currency.AGGREGATE_TYPE, item.getId(), item))
.chain(item -> domainEventDispatcher.dispatchAndClear(item).replaceWith(item))
.map(item -> ResponseObject.success(item.getId().getValue(), Response.Status.CREATED.getStatusCode()));
< /code>
domaineventdispatcher.dispatchandClear реализован так: < /p>
public Uni dispatchAndClear(AbstractAggregate aggregate) {
var events = List.copyOf(aggregate.getDomainEvents());
return Multi.createFrom().iterable(events)
.onItem().transformToUniAndConcatenate(this::dispatch)
.collect().asList()
.replaceWithVoid()
.invoke(aggregate::clearDomainEvents);
< /code>
} < /p>
Я получил следующую ошибку. io.quarkus.hibernate.reactive.panache.common.runtime.sessionoperations.vertxcontext (sessionoperations.java:193)
может кто -нибудь мне помочь?
Подробнее здесь: https://stackoverflow.com/questions/797 ... tateexcept
