From a25b3147b62637a0942aa6ee4e682145a95f9dcf Mon Sep 17 00:00:00 2001
From: Janne Valkealahti <janne.valkealahti@gmail.com>
Date: Sun, 1 Nov 2020 13:11:47 +0000
Subject: [PATCH] Fix trigger sink usage

---
 .../statemachine/support/ReactiveStateMachineExecutor.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 ac31095a..f2f1ec35 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
@@ -157,7 +157,10 @@ public class ReactiveStateMachineExecutor<S, E> extends LifecycleObjectSupport i
 		if (log.isDebugEnabled()) {
 			log.debug("Queue trigger " + trigger);
 		}
-		triggerSink.emitNext(new TriggerQueueItem(trigger, message, null, null), Sinks.EmitFailureHandler.FAIL_FAST);
+		TriggerQueueItem tqi = new TriggerQueueItem(trigger, message, null, null);
+		while (triggerSink.tryEmitNext(tqi).isFailure()) {
+			LockSupport.parkNanos(10);
+		}
 	}
 
 	@Override