diff --git a/spring-shell-core/src/main/java/org/springframework/shell/component/view/event/processor/TaskEventLoopProcessor.java b/spring-shell-core/src/main/java/org/springframework/shell/component/view/event/processor/TaskEventLoopProcessor.java index d6cf9550..55aa622b 100644 --- a/spring-shell-core/src/main/java/org/springframework/shell/component/view/event/processor/TaskEventLoopProcessor.java +++ b/spring-shell-core/src/main/java/org/springframework/shell/component/view/event/processor/TaskEventLoopProcessor.java @@ -32,7 +32,7 @@ public class TaskEventLoopProcessor implements EventLoopProcessor { public boolean canProcess(Message message) { if (EventLoop.Type.TASK.equals(StaticShellMessageHeaderAccessor.getEventType(message))) { Object payload = message.getPayload(); - if (payload instanceof Runnable r) { + if (payload instanceof Runnable) { return true; } else if(payload instanceof KeyBindingConsumerArgs) { @@ -48,7 +48,7 @@ public class TaskEventLoopProcessor implements EventLoopProcessor { @Override public Flux> process(Message message) { Object payload = message.getPayload(); - if (payload instanceof Runnable r) { + if (payload instanceof Runnable) { return processRunnable(message); } else if(payload instanceof KeyBindingConsumerArgs) {