Fixed FixedThreadPoolBulkhead: A CompletionException should not be wr…

…apped inside of another CompletionException.
jihoonson · Feb 4, 2020 · 476151a · 476151a
1 parent 22931ca
commit 476151a
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...khead/src/main/java/io/github/resilience4j/bulkhead/internal/FixedThreadPoolBulkhead.java b/...khead/src/main/java/io/github/resilience4j/bulkhead/internal/FixedThreadPoolBulkhead.java
@@ -142,10 +142,9 @@ public <T> CompletableFuture<T> submit(Callable<T> callable) {
                 try {
                     publishBulkheadEvent(() -> new BulkheadOnCallPermittedEvent(name));
                     return callable.call();
-                } catch (Exception e) {
-                    if(e instanceof CompletionException){
-                        throw (CompletionException)e;
-                    }
+                } catch (CompletionException e) {
+                    throw e;
+                } catch (Exception e){
                     throw new CompletionException(e);
                 }
             }), executorService).whenComplete((result, throwable) -> {