do not cache managedexecutorservice among interceptor calls

eclipse-ee4j · May 13, 2022 · 92a0ab7 · 92a0ab7
1 parent cfed537
commit 92a0ab7
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/src/main/java/org/glassfish/enterprise/concurrent/AsynchronousInterceptor.java b/src/main/java/org/glassfish/enterprise/concurrent/AsynchronousInterceptor.java
@@ -62,14 +62,10 @@
 public class AsynchronousInterceptor {
     static final Logger log = Logger.getLogger(AsynchronousInterceptor.class.getName());
 
-    private ManagedExecutorService mes = null;
-
     @AroundInvoke
     public Object intercept(InvocationContext context) throws Exception {
-        if (mes == null) {
-            String executor = context.getMethod().getAnnotation(Asynchronous.class).executor();
-            mes = (ManagedExecutorService) new InitialContext().lookup(executor != null ? executor : "java:comp/DefaultManagedExecutorService");
-        }
+        String executor = context.getMethod().getAnnotation(Asynchronous.class).executor();
+        ManagedExecutorService mes = (ManagedExecutorService) new InitialContext().lookup(executor != null ? executor : "java:comp/DefaultManagedExecutorService");
         log.fine("AsynchronousInterceptor.intercept");
         CompletableFuture<Object> resultFuture = new ManagedCompletableFuture<>(mes);
         mes.submit(() -> {