Fix trigger sink usage

This commit is contained in:
Janne Valkealahti
2020-11-01 13:11:47 +00:00
parent 3d2e1de237
commit a25b3147b6

View File

@@ -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