[DRAFT 1751] Limit the time waiting for a handler to finish

Bug: #1751
Signed-off-by: Pierre-Charles David <[email protected]>

packages/core/backend/sirius-components-collaborative/src/main/java/org/eclipse/sirius/components/collaborative/editingcontext/EditingContextEventProcessor.java

@@ -24,6 +24,8 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
 import java.util.function.Consumer;
 import java.util.logging.Level;
 import java.util.stream.Collectors;
@@ -214,9 +216,14 @@ public Mono<IPayload> handle(IInput input) {
         Future<?> future = this.executorService.submit(() -> this.doHandle(payloadSink, input));
         try {
             // Block until the event has been processed
-            future.get();
+            future.get(5, TimeUnit.SECONDS);
         } catch (InterruptedException | ExecutionException exception) {
             this.logger.warn(exception.getMessage(), exception);
+        } catch (TimeoutException e) {
+            // The handler did not finish, try to cancel it and return an error immeditaly instead of waiting (and
+            // blocking the current thread) indefinitely.
+            future.cancel(true);
+            return Mono.just((IPayload) new ErrorPayload(input.id(), this.messageService.timeout()));
         }
 
         // @formatter:off