Examples of SessionPool

com.caucho.ejb.SessionPool
com.volantis.mps.session.pool.SessionPool
Common superclass for both the actual and unpooled (i.e. creates a new session for each request) session pool implementations. @mock.generate
com.vtence.molecule.session.SessionPool
org.apache.camel.component.sjms.jms.SessionPool
TODO Add Class documentation for SessionPool
org.apache.sling.jcr.base.internal.SessionPool
The SessionPool class implementins pooling and reusing sessions with the defined limits. See {@link #acquireSession(SimpleCredentials,String)}and {@link #acquireSession(Session,Credentials)} for details.
org.codehaus.wadi.SessionPool

Examples of com.caucho.ejb.SessionPool

  }


  private void introspect()
  {
    AnnotatedType<?> annType = getAnnotatedType();
    SessionPool sessionPool = annType.getAnnotation(SessionPool.class);


    if (sessionPool != null) {
      if (sessionPool.maxIdle() >= 0)
        _sessionIdleMax = sessionPool.maxIdle();
      
      if (sessionPool.maxConcurrent() >= 0)
        _sessionConcurrentMax = sessionPool.maxConcurrent();
      
      if (sessionPool.maxConcurrentTimeout() >= 0)
        _sessionConcurrentTimeout = sessionPool.maxConcurrentTimeout();
    }
  }

View Full Code Here

Examples of com.caucho.ejb.SessionPool

      super.init();


      InjectManager beanManager = InjectManager.create();
      
      AnnotatedType<?> annType = getAnnotatedType();
      SessionPool sessionPool = annType.getAnnotation(SessionPool.class);
      
      if (sessionPool != null) {
        if (sessionPool.maxIdle() >= 0)
          _sessionIdleMax = sessionPool.maxIdle();
        
        if (sessionPool.maxConcurrent() >= 0)
          _sessionConcurrentMax = sessionPool.maxConcurrent();
        
        if (sessionPool.maxConcurrentTimeout() >= 0)
          _sessionConcurrentTimeout = sessionPool.maxConcurrentTimeout();
        
      }


      BeanFactory<SessionContext> factory
        = beanManager.createBeanFactory(SessionContext.class);

View Full Code Here

Examples of com.volantis.mps.session.pool.SessionPool

     */
    private SessionPool initializeSessionPool(
            Map channelInfo, PoolableObjectFactory sessionFactory)
            throws MessageException {


        final SessionPool sessionPool;
        if (!supportsPooling) {
            // If session pooling isn't supported, then we don't need to
            // check the rest of the session pooling configuration, but can
            // just create an UnpooledSessionPool which just creates a new
            // Session for each request.

View Full Code Here

Examples of com.vtence.molecule.session.SessionPool

        this.sessionTracker.expireAfter(seconds);
    }


    public void run(WebServer server) throws IOException {
        // Track sessions using a cookie strategy and an in-memory session pool
        sessionTracker = new CookieSessionTracker(new SessionPool(new SecureIdentifierPolicy(), clock));
        server.add(sessionTracker)
              .start(new DynamicRoutes() {{
                         map("/").to(new Application() {
                             public void handle(Request request, Response response) throws Exception {
                                 Session session = Session.get(request);

View Full Code Here

Examples of org.apache.camel.component.sjms.jms.SessionPool

        //
        // We only create a session pool when we are not transacted.
        // Transacted listeners or producers need to be paired with the
        // Session that created them.
        if (!isTransacted() && getExchangePattern().equals(ExchangePattern.InOnly)) {
            sessions = new SessionPool(getSessionCount(), getConnectionResource());


            // TODO fix the string hack
            sessions.setAcknowledgeMode(SessionAcknowledgementType.valueOf(getAcknowledgementMode() + ""));
            getSessions().fillPool();
        }

View Full Code Here

Examples of org.apache.camel.component.sjms.jms.SessionPool

        //
        // We only create a session pool when we are not transacted.
        // Transacted listeners or producers need to be paired with the
        // Session that created them.
        if (!isTransacted() && getExchangePattern().equals(ExchangePattern.InOnly)) {
            sessions = new SessionPool(getSessionCount(), getConnectionResource());


            // TODO fix the string hack
            sessions.setAcknowledgeMode(SessionAcknowledgementType.valueOf(getAcknowledgementMode() + ""));
            getSessions().fillPool();
        }

View Full Code Here

Examples of org.apache.camel.component.sjms.jms.SessionPool

        //
        // We only create a session pool when we are not transacted.
        // Transacted listeners or producers need to be paired with the
        // Session that created them.
        if (!isTransacted() && getExchangePattern().equals(ExchangePattern.InOnly)) {
            sessions = new SessionPool(getSessionCount(), getConnectionResource());


            // TODO fix the string hack
            sessions.setAcknowledgeMode(SessionAcknowledgementType.valueOf(getAcknowledgementMode() + ""));
            getSessions().fillPool();
        }

View Full Code Here

Examples of org.apache.sling.jcr.base.internal.SessionPool

        return new SessionPoolFactory() {


            public SessionPool createPool(final SessionPoolManager mgr,
                    final SimpleCredentials credentials) {
                // create and configure the new pool
                final SessionPool pool = createSessionPool(mgr, credentials);
                pool.setMaxActiveSessions(maxActiveSessions);
                pool.setMaxActiveSessionsWait(maxActiveSessionsWait);
                pool.setMaxIdleSessions(maxIdleSessions);
                return pool;
            }
        };
    }

View Full Code Here

Examples of org.apache.sling.jcr.base.internal.SessionPool

        };
    }


    protected SessionPool createSessionPool(final SessionPoolManager mgr,
            final SimpleCredentials credentials) {
        final SessionPool pool = new SessionPool(mgr, credentials);
        return pool;
    }

View Full Code Here

Examples of org.apache.sling.jcr.base.internal.SessionPool

        return new SessionPoolFactory() {


            public SessionPool createPool(final SessionPoolManager mgr,
                    final SimpleCredentials credentials) {
                // create and configure the new pool
                final SessionPool pool = createSessionPool(mgr, credentials);
                pool.setMaxActiveSessions(maxActiveSessions);
                pool.setMaxActiveSessionsWait(maxActiveSessionsWait);
                pool.setMaxIdleSessions(maxIdleSessions);
                return pool;
            }
        };
    }

View Full Code Here

0 1

TOP

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.