A really simple Async CDI extension

Async.java

import javax.interceptor.InterceptorBinding;
import java.lang.annotation.ElementType;
import java.lang.annotation.Inherited;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Inherited
@InterceptorBinding
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE, ElementType.METHOD})
public @interface Async {
}

AsyncBean.java

@ApplicationScoped
@Async
public class AsyncBean {

    public Future<Object> doLongCall() {
        try {
            Thread.sleep(1000);

            System.out.println("Current thread "+Thread.currentThread().getName());

            Thread.sleep(1000);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return CompletableFuture.completedFuture("I am the returned value");
    }
}

AsyncInterceptor.java

import javax.annotation.Priority;
import javax.enterprise.context.Dependent;
import javax.interceptor.AroundInvoke;
import javax.interceptor.Interceptor;
import javax.interceptor.InvocationContext;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@Async
@Interceptor
@Priority(1001)
@Dependent
public class AsyncInterceptor {

    @AroundInvoke
    public Object runInThread(InvocationContext ctx) throws Exception {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        return executorService.submit(ctx::proceed);
    }

}

AsyncTest.java

import org.jboss.arquillian.container.test.api.Deployment;
import org.jboss.arquillian.junit.Arquillian;
import org.jboss.shrinkwrap.api.ShrinkWrap;
import org.jboss.shrinkwrap.api.asset.EmptyAsset;
import org.jboss.shrinkwrap.api.spec.JavaArchive;
import org.junit.Test;
import org.junit.runner.RunWith;

import javax.inject.Inject;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

@RunWith(Arquillian.class)
public class AsyncTest {
    @Deployment
    public static JavaArchive create() {
        return ShrinkWrap.create(JavaArchive.class).addClasses(Async.class, AsyncBean.class, AsyncInterceptor.class).addAsManifestResource(EmptyAsset.INSTANCE, "beans.xml");
    }

    @Inject
    private AsyncBean asyncBean;

    @Test
    public void shouldRunAsync() throws Exception {
        Future<Object> objectFuture = asyncBean.doLongCall();
        System.out.println("Object future called");
        Object o = objectFuture.get(3, TimeUnit.SECONDS);
        CompletableFuture<Object> cf = (CompletableFuture<Object>)o;
        System.out.println("The output: "+ cf.get());
    }
}