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
index 26f063bf2..93811fa79 100644
--- 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)) {