add @Priority on it or declare it in beans.Xml
Romain Manni-Bucau @rmannibucau <https://twitter.com/rmannibucau> | Blog <https://blog-rmannibucau.rhcloud.com> | Old Blog <http://rmannibucau.wordpress.com> | Github <https://github.com/rmannibucau> | LinkedIn <https://www.linkedin.com/in/rmannibucau> | JavaEE Factory <https://javaeefactory-rmannibucau.rhcloud.com> 2017-01-25 13:59 GMT+01:00 cocorossello <cocorosse...@gmail.com>: > It's not, my bad. The interceptor was not being applied and I thought it > was OK. > > The problem I have now is that the excutor is not being inyected. > > @Resource(name = "TravelcAsynchronousPool") > private ManagedExecutorService executor; > > > And it is declared in resources.xml > > > <Resource id="TravelcAsynchronousPool" type="ManagedExecutorService"> > Core 100 > Max 200 > Queue 1500 > KeepAlive 1 s > ThreadFactory > org.apache.openejb.threads.impl.ManagedThreadFactoryImpl > Lazy true > </Resource> > > > > On Wed, Jan 25, 2017 at 1:53 PM, Romain Manni-Bucau [via TomEE & OpenEJB] < > ml-node+s979440n4680932...@n4.nabble.com> wrote: > > > Does it work? shouldn't it be: > > > > @AroundInvoke > > public Object submitAsync(InvocationContext ctx) throws Exception { > > return executor.submit(new FutureDelegator(() -> { // in the > > constructor capture current MDC and (re)set it ManagedTaskListener hooks > > return ctx.proceed(); > > })); > > } > > > > > > Romain Manni-Bucau > > @rmannibucau <https://twitter.com/rmannibucau> | Blog > > <https://blog-rmannibucau.rhcloud.com> | Old Blog > > <http://rmannibucau.wordpress.com> | Github <https://github.com/ > > rmannibucau> | > > LinkedIn <https://www.linkedin.com/in/rmannibucau> | JavaEE Factory > > <https://javaeefactory-rmannibucau.rhcloud.com> > > > > 2017-01-25 13:24 GMT+01:00 cocorossello <[hidden email] > > <http:///user/SendEmail.jtp?type=node&node=4680932&i=0>>: > > > > > I got it, this is the code just in case anyone needs it. > > > > > > > > > @InterceptorBinding > > > @Target({TYPE, METHOD}) > > > @Retention(RUNTIME) > > > @Inherited > > > public @interface Async { > > > > > > } > > > > > > > > > > > > @Async > > > @Interceptor > > > public class AsyncInterceptor implements Serializable { > > > > > > @Resource(name = "TravelcAsynchronousPool") > > > private ManagedExecutorService executor; > > > > > > @AroundInvoke > > > public Object submitAsync(InvocationContext ctx) throws Exception { > > > return new FutureDelegator(executor.submit(() -> { > > > return ctx.proceed(); > > > })); > > > } > > > } > > > > > > > > > > > > > > > > > > > > > public class FutureDelegator implements Future, ManagedTask, > > > ManagedTaskListener { > > > > > > private final Future<?> future; > > > private Map<String, String> mdcCopy; > > > > > > public FutureDelegator(Future<?> future) { > > > this.future = future; > > > } > > > > > > @Override > > > public Object get() throws InterruptedException, ExecutionException > > { > > > AsyncResult<?> asyncResult = (AsyncResult<?>) future.get(); > > > if (asyncResult == null) { > > > return null; > > > } > > > > > > return asyncResult.get(); > > > } > > > > > > @Override > > > public Object get(long timeout, TimeUnit unit) throws > > > InterruptedException, ExecutionException, TimeoutException { > > > AsyncResult<?> asyncResult = (AsyncResult<?>) > > future.get(timeout, > > > unit); > > > if (asyncResult == null) { > > > return null; > > > } > > > > > > return asyncResult.get(); > > > } > > > > > > @Override > > > public boolean cancel(boolean mayInterruptIfRunning) { > > > return future.cancel(mayInterruptIfRunning); > > > } > > > > > > @Override > > > public boolean isCancelled() { > > > return future.isCancelled(); > > > } > > > > > > @Override > > > public boolean isDone() { > > > return future.isDone(); > > > } > > > > > > @Override > > > public ManagedTaskListener getManagedTaskListener() { > > > return this; > > > } > > > > > > @Override > > > public Map<String, String> getExecutionProperties() { > > > return new HashMap(); > > > } > > > > > > @Override > > > public void taskSubmitted(Future<?> future, ManagedExecutorService > > > executor, Object task) { > > > mdcCopy = MDC.getCopyOfContextMap(); > > > } > > > > > > @Override > > > public void taskAborted(Future<?> future, ManagedExecutorService > > > executor, Object task, Throwable exception) { > > > //NADA > > > } > > > > > > @Override > > > public void taskDone(Future<?> future, ManagedExecutorService > > executor, > > > Object task, Throwable exception) { > > > //NADA > > > } > > > > > > @Override > > > public void taskStarting(Future<?> future, ManagedExecutorService > > > executor, Object task) { > > > MDC.setContextMap(mdcCopy); > > > } > > > } > > > > > > > > > > > > > > > -- > > > View this message in context: http://tomee-openejb.979440. > > > n4.nabble.com/MDC-and-Asynchronous-tp4680927p4680931.html > > > Sent from the TomEE Users mailing list archive at Nabble.com. > > > > > > > > > ------------------------------ > > If you reply to this email, your message will be added to the discussion > > below: > > http://tomee-openejb.979440.n4.nabble.com/MDC-and-Asynchronous- > > tp4680927p4680932.html > > To unsubscribe from MDC and @Asynchronous, click here > > <http://tomee-openejb.979440.n4.nabble.com/template/ > NamlServlet.jtp?macro=unsubscribe_by_code&node=4680927&code= > Y29jb3Jvc3NlbGxvQGdtYWlsLmNvbXw0NjgwOTI3fC05Mzc2MzQ4MzY=> > > . > > NAML > > <http://tomee-openejb.979440.n4.nabble.com/template/ > NamlServlet.jtp?macro=macro_viewer&id=instant_html% > 21nabble%3Aemail.naml&base=nabble.naml.namespaces. > BasicNamespace-nabble.view.web.template.NabbleNamespace- > nabble.view.web.template.NodeNamespace&breadcrumbs= > notify_subscribers%21nabble%3Aemail.naml-instant_emails% > 21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> > > > > > > > -- > View this message in context: http://tomee-openejb.979440. > n4.nabble.com/MDC-and-Asynchronous-tp4680927p4680933.html > Sent from the TomEE Users mailing list archive at Nabble.com. >
