エラー処理のすべてのセットアップを行いました
@PostConstruct
public void addStateMachineInterceptor() {
stateMachine.getStateMachineAccessor().withRegion().addStateMachineInterceptor(interceptor);
stateMachine.getStateMachineAccessor().doWithRegion(errorinterceptor);
}
エラーを処理するインターセプターを作成しました:
@Service
public class OrderStateMachineFunction<T> implements StateMachineFunction<StateMachineAccess<String, String>> {
@Override
public void apply(StateMachineAccess<String, String> stringStringStateMachineAccess) {
stringStringStateMachineAccess.addStateMachineInterceptor(
new StateMachineInterceptorAdapter<String, String>() {
@Override
public Exception stateMachineError(StateMachine<String, String> stateMachine,
Exception exception) {
// return null indicating handled error
return exception;
}
});
}
}
しかし、アクションから例外をスローするときに、呼び出しが OrderStateMachineFunction に入ることはわかりません。
その後、ステート マシンは、this.stateMachine.sendEvent(eventData); の後で preStateChange メソッドの呼び出しを停止するなど、有線の方法で動作します。アクションから例外をスローした後、ステート マシンが壊れているようです。
@Service
public class OrderStateMachineInterceptor extends StateMachineInterceptorAdapter {
@Override
public void preStateChange(State newState, Message message, Transition transition, StateMachine stateMachine) {
System.out.println("Manish");
}
}
少し試してみたところ、resetStateMachine にコメントすると期待どおりに動作することがわかりましたが、それがないと currentstate をステート マシンに通知できません。
public boolean fireEvent(Object data, String previousState, String event) {
Message<String> eventData = MessageBuilder.withPayload(event)
.setHeader(DATA_KEY, data)
.build();
this.stateMachine.stop();
// this.stateMachine
// .getStateMachineAccessor()
// .withRegion()
// .resetStateMachine(new DefaultStateMachineContext(previousState, event, eventData.getHeaders(), null));
this.stateMachine.start();
return this.stateMachine.sendEvent(eventData);
}