问题描述
@JmsListener(destination = "MY_EVENT_TOPIC",selector = "_type = 'REVIEW_SUBMITTED_EVENT'")
public void onEvent(ReviewSubmittedEvent event) {
Saga saga = Saga.builder()
.name("ReviewCheckingSaga")
.key(event.getReviewId())
.handler("reviewCheckingService")
.requiredEvent(ReviewSubmittedEvent.class.getName())
.requiredEvent(ReviewInExaminationEvent.class.getName())
.requiredEvent(ReviewApprovedEvent.class.getName())
.rejectionEvent(ReviewRejectedEvent.class.getName())
.build();
sagaService.save(ReviewCheckingSaga);
sagaService.apply("ReviewCheckingSaga",event.getReviewId(),event);
}
尝试获取spring boot的实现,但是这里有问题。我不知道为什么它不起作用并且有错误。请帮忙!
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)