Examples of registerDeferredResultInterceptor()


Examples of org.springframework.web.context.request.async.WebAsyncManager.registerDeferredResultInterceptor()

          EntityManagerHolder emHolder = new EntityManagerHolder(em);
          TransactionSynchronizationManager.bindResource(emf, emHolder);

          AsyncRequestInterceptor interceptor = new AsyncRequestInterceptor(emf, emHolder);
          asyncManager.registerCallableInterceptor(key, interceptor);
          asyncManager.registerDeferredResultInterceptor(key, interceptor);
        }
        catch (PersistenceException ex) {
          throw new DataAccessResourceFailureException("Could not create JPA EntityManager", ex);
        }
      }
View Full Code Here

Examples of org.springframework.web.context.request.async.WebAsyncManager.registerDeferredResultInterceptor()

        EntityManagerHolder emHolder = new EntityManagerHolder(em);
        TransactionSynchronizationManager.bindResource(getEntityManagerFactory(), emHolder);

        AsyncRequestInterceptor interceptor = new AsyncRequestInterceptor(getEntityManagerFactory(), emHolder);
        asyncManager.registerCallableInterceptor(participateAttributeName, interceptor);
        asyncManager.registerDeferredResultInterceptor(participateAttributeName, interceptor);
      }
      catch (PersistenceException ex) {
        throw new DataAccessResourceFailureException("Could not create JPA EntityManager", ex);
      }
    }
View Full Code Here

Examples of org.springframework.web.context.request.async.WebAsyncManager.registerDeferredResultInterceptor()

          SessionHolder sessionHolder = new SessionHolder(session);
          TransactionSynchronizationManager.bindResource(sessionFactory, sessionHolder);

          AsyncRequestInterceptor interceptor = new AsyncRequestInterceptor(sessionFactory, sessionHolder);
          asyncManager.registerCallableInterceptor(key, interceptor);
          asyncManager.registerDeferredResultInterceptor(key, interceptor);
        }
      }
    }
    else {
      // deferred close mode
View Full Code Here

Examples of org.springframework.web.context.request.async.WebAsyncManager.registerDeferredResultInterceptor()

      TransactionSynchronizationManager.bindResource(getSessionFactory(), sessionHolder);

      AsyncRequestInterceptor asyncRequestInterceptor =
          new AsyncRequestInterceptor(getSessionFactory(), sessionHolder);
      asyncManager.registerCallableInterceptor(participateAttributeName, asyncRequestInterceptor);
      asyncManager.registerDeferredResultInterceptor(participateAttributeName, asyncRequestInterceptor);
    }
  }

  @Override
  public void postHandle(WebRequest request, ModelMap model) {
View Full Code Here

Examples of org.springframework.web.context.request.async.WebAsyncManager.registerDeferredResultInterceptor()

        SessionHolder sessionHolder = new SessionHolder(session);
        TransactionSynchronizationManager.bindResource(sessionFactory, sessionHolder);

        AsyncRequestInterceptor interceptor = new AsyncRequestInterceptor(sessionFactory, sessionHolder);
        asyncManager.registerCallableInterceptor(key, interceptor);
        asyncManager.registerDeferredResultInterceptor(key, interceptor);
      }
    }

    try {
      filterChain.doFilter(request, response);
View Full Code Here

Examples of org.springframework.web.context.request.async.WebAsyncManager.registerDeferredResultInterceptor()

        TransactionSynchronizationManager.bindResource(getSessionFactory(), sessionHolder);

        AsyncRequestInterceptor asyncRequestInterceptor =
            new AsyncRequestInterceptor(getSessionFactory(), sessionHolder);
        asyncManager.registerCallableInterceptor(participateAttributeName, asyncRequestInterceptor);
        asyncManager.registerDeferredResultInterceptor(participateAttributeName, asyncRequestInterceptor);
      }
      else {
        // deferred close mode
        SessionFactoryUtils.initDeferredClose(getSessionFactory());
      }
View Full Code Here

Examples of org.springframework.web.context.request.async.WebAsyncManager.registerDeferredResultInterceptor()

      @Override
      public <T> void postProcess(NativeWebRequest r, Callable<T> task, Object value) throws Exception {
        getMvcResult(request).setAsyncResult(value);
      }
    });
    asyncManager.registerDeferredResultInterceptor(KEY, new DeferredResultProcessingInterceptorAdapter() {
      @Override
      public <T> void postProcess(NativeWebRequest r, DeferredResult<T> result, Object value) throws Exception {
        getMvcResult(request).setAsyncResult(value);
      }
    });
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.