Я пытаюсь отправить событие с зарегистрированного ListenerInvocationErrorHandler
, обработчик привязан к каждому типу саги через subscribingSagaManager()
и зарегистрирован так:
private static <S extends BasicSaga> SagaConfiguration<S> registerSaga(Class<S> sagaType) {
return SagaConfiguration.subscribingSagaManager(sagaType).configureListenerInvocationErrorHandler(...)
}
Выявление ошибки и отправка события здесь:
private static ListenerInvocationErrorHandler getListenerInvocationErrorHandler(EventBus eventBus) {
// code below is the callback for errors
return (Exception e, EventMessage<?> event, EventListener eventListener) -> {
...
eventBus.publish(new GenericEventMessage<>(new Events.someEvent(myProperty)));
}
}
При срабатывании этого кода AssociationProperty имеет значение null и информация саги не разрешена.
@EndSaga
@SagaEventHandler(associationProperty = "myProp")
public void doSomething(Events.someEvent) {
...
// Should resolve the associationProperty, but when debugged the value is null.
}
Мое событие заполняется всеми правильными полями , и свойство associationProperty в событии НЕ имеет значения null.
Возможно ли, что это произошло из-за того, что сага закончилась?
Любая помощь будет принята с благодарностью!