Fix #1162

mrodal · fmbenhassine · commit f31d2b1a7775 · 2025-05-29T00:06:02.000+02:00
diff --git a/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/ReactiveStateMachineExecutor.java b/spring-statemachine-core/src/main/java/org/springframework/statemachine/support/ReactiveStateMachineExecutor.java
@@ -125,7 +125,7 @@ protected Mono<Void> doPreStartReactively() {
 			Mono<Void> mono = startTriggers();
 
 			if (triggerDisposable == null) {
-				triggerDisposable = triggerFlux.subscribe();
+				triggerDisposable = triggerFlux.contextCapture().subscribe();
 			}
 
 			if (!initialHandled.getAndSet(true)) {

Original file line number	Diff line number	Diff line change
`@@ -125,7 +125,7 @@ protected Mono<Void> doPreStartReactively() {`
`125`	`125`	`Mono<Void> mono = startTriggers();`
`126`	`126`
`127`	`127`	`if (triggerDisposable == null) {`
`128`		`- triggerDisposable = triggerFlux.subscribe();`
	`128`	`+ triggerDisposable = triggerFlux.contextCapture().subscribe();`
`129`	`129`	`}`
`130`	`130`
`131`	`131`	`if (!initialHandled.getAndSet(true)) {`