@Dependent
public class SubscribeEndpoint  {

    protected final Logger logger = LoggerFactory.getLogger(getClass());
    private ThreadPoolExecutor executorService;
    private ManagedThreadFactory threadFactory;

    public SubscribeEndpoint() {
        try {
            threadFactory = ServiceLocator.getInstance().lookupRemote("concurrent/ThreadFactory");
            executorService = new ThreadPoolExecutor(5, 10, 5, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10), threadFactory);
        } catch (NamingException e) {
            logger.error("Exception: ", e);
        }
    }


    public void onMessage(Message message) {
        try {           
            SubscribeHandler handler = getSubscribeHandler();
            executorService.submit(() -> handler.runMessageProcessing(message));
        } catch (Throwable e) {
            logger.error("Exception: ", e);
        }
    }

}

executorService.submit(() -> handler.runMessageProcessing(message));

getSubscribeHandler();

 Future.get()

@Dependent
public class SubscribeEndpoint  {

    protected final Logger logger = LoggerFactory.getLogger(getClass());
    private ManagedExecutorService executorService;

    public SubscribeEndpoint() {
        try {
            executorService = ServiceLocator.getInstance().lookupRemote("concurrent/NatsMES");
        } catch (NamingException e) {
            logger.error("Exception: ", e);
        }
    }


    public void onMessage(Message message) {
            SubscribeHandler handler = getSubscribeHandler();
            executorService.submit(() -> {
                try {
                    handler.runMessageProcessing(message);
                } catch (Throwable e) {
                    logger.error("Exception: ", e);
                }
            });
    }

protected String getHandlerJNDIName() {
        return ConfigurationHandler.JNDI_GLOBAL_NAME;
    }

protected <T extends SubscribeHandler> T getSubscribeHandler() {
         T handler = null;
        try {
            handler = ServiceLocator.getInstance().lookupRemote(getHandlerJNDIName());
        } catch (NamingException e) {
            logger.error("Exception: ", e);
        }
        
        return handler;
    }

}

 Future.get()