Examples of PoolConfiguration

net.dataforte.cassandra.pool.PoolConfiguration
org.apache.tomcat.jdbc.pool.PoolConfiguration
A list of properties that are configurable for a connection pool. The {@link DataSource} object also implements this interface so that it can be easily configured throughan IoC container without having to specify a secondary object with a setter method. @author fhanik
org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration
The pool configuration. @author Gurkan Erdogdu @author Jesper Pedersen
org.ow2.util.pool.impl.enhanced.PoolConfiguration
This class manages the injection. @author Florent Benoit

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

     * @param tp The timeout parameters
     * @param vp The validation parameters
     * @return The configuration
     */
    protected PoolConfiguration createPoolConfiguration(final CommonPool pp, final CommonTimeOut tp, final CommonValidation vp) {
        final PoolConfiguration pc = new PoolConfiguration();


        if (pp != null) {
            if (pp.getMinPoolSize() != null)
                pc.setMinSize(pp.getMinPoolSize().intValue());


            if (pp.getMaxPoolSize() != null)
                pc.setMaxSize(pp.getMaxPoolSize().intValue());


            if (pp.isPrefill() != null)
                pc.setPrefill(pp.isPrefill());


            if (pp.isUseStrictMin() != null)
                pc.setStrictMin(pp.isUseStrictMin());
        }


        if (tp != null) {
            if (tp.getBlockingTimeoutMillis() != null)
                pc.setBlockingTimeout(tp.getBlockingTimeoutMillis().longValue());


            if (tp.getIdleTimeoutMinutes() != null)
                pc.setIdleTimeout(tp.getIdleTimeoutMinutes().longValue());
        }


        if (vp != null) {
            if (vp.isBackgroundValidation() != null)
                pc.setBackgroundValidation(vp.isBackgroundValidation().booleanValue());


            if (vp.getBackgroundValidationMinutes() != null)
                pc.setBackgroundValidationMinutes(vp.getBackgroundValidationMinutes().intValue());


            if (vp.isUseFastFail() != null)
                pc.setUseFastFail(vp.isUseFastFail());
        }


        return pc;
    }

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

            if (repository.getConnectors() != null) {
                for (Connector conn : repository.getConnectors()) {
                    if (jndiName.equalsIgnoreCase(conn.getUniqueId())) {
                        if (conn.getConnectionFactories() == null || conn.getConnectionFactories().get(0) == null)
                            continue;
                        PoolConfiguration pc = conn.getConnectionFactories().get(0).getPoolConfiguration();
                        result.add(pc);
                    }


                }
            }

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

            if (repository.getConnectors() != null) {
                for (Connector conn : repository.getConnectors()) {
                    if (jndiName.equalsIgnoreCase(conn.getUniqueId())) {
                        if (conn.getConnectionFactories() == null || conn.getConnectionFactories().get(0) == null)
                            continue;
                        PoolConfiguration pc = conn.getConnectionFactories().get(0).getPoolConfiguration();
                        result.add(pc);
                    }


                }
            }

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

            if (repository.getConnectors() != null) {
                for (Connector conn : repository.getConnectors()) {
                    if (jndiName.equalsIgnoreCase(conn.getUniqueId())) {
                        if (conn.getConnectionFactories() == null || conn.getConnectionFactories().get(0) == null)
                            continue;
                        PoolConfiguration pc = conn.getConnectionFactories().get(0).getPoolConfiguration();
                        result.add(pc);
                    }


                }
            }

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

            if (repository.getConnectors() != null) {
                for (Connector conn : repository.getConnectors()) {
                    if (jndiName.equalsIgnoreCase(conn.getUniqueId())) {
                        if (conn.getConnectionFactories() == null || conn.getConnectionFactories().get(0) == null)
                            continue;
                        PoolConfiguration pc = conn.getConnectionFactories().get(0).getPoolConfiguration();
                        result.add(pc);
                    }


                }
            }

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

        }
        return xaManagedConnectionFactory;
    }


    protected Pool createPool(final String jndiName, final ManagedConnectionFactory mcf) {
        final PoolConfiguration pc = createPoolConfiguration(dataSourceConfig.getXaPool(), dataSourceConfig.getTimeOut(),
                dataSourceConfig.getValidation());


        Boolean noTxSeparatePool = Boolean.FALSE;


        if (dataSourceConfig.getXaPool() != null && dataSourceConfig.getXaPool().isNoTxSeparatePool() != null) {

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration


        return managedConnectionFactory;
    }


    protected Pool createPool(final String jndiName, final ManagedConnectionFactory mcf) {
        final PoolConfiguration pc = createPoolConfiguration(dataSourceConfig.getPool(), dataSourceConfig.getTimeOut(),
                dataSourceConfig.getValidation());
        PoolFactory pf = new PoolFactory();
        final Pool pool = pf.create(PoolStrategy.ONE_POOL, mcf, pc, false);


        String poolName = null;

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

     * @param tp The timeout parameters
     * @param vp The validation parameters
     * @return The configuration
     */
    protected PoolConfiguration createPoolConfiguration(final CommonPool pp, final CommonTimeOut tp, final CommonValidation vp) {
        final PoolConfiguration pc = new PoolConfiguration();


        if (pp != null) {
            if (pp.getMinPoolSize() != null)
                pc.setMinSize(pp.getMinPoolSize().intValue());


            if (pp.getMaxPoolSize() != null)
                pc.setMaxSize(pp.getMaxPoolSize().intValue());


            if (pp.isPrefill() != null)
                pc.setPrefill(pp.isPrefill());


            if (pp.isUseStrictMin() != null)
                pc.setStrictMin(pp.isUseStrictMin());
        }


        if (tp != null) {
            if (tp.getBlockingTimeoutMillis() != null)
                pc.setBlockingTimeout(tp.getBlockingTimeoutMillis().longValue());


            if (tp.getIdleTimeoutMinutes() != null)
                pc.setIdleTimeout(tp.getIdleTimeoutMinutes().longValue());
        }


        if (vp != null) {
            if (vp.isBackgroundValidation() != null)
                pc.setBackgroundValidation(vp.isBackgroundValidation().booleanValue());


            if (vp.getBackgroundValidationMinutes() != null)
                pc.setBackgroundValidationMinutes(vp.getBackgroundValidationMinutes().intValue());


            if (vp.isUseFastFail() != null)
                pc.setUseFastFail(vp.isUseFastFail());
        }


        return pc;
    }

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

    }


    public synchronized void start(StartContext startContext) throws StartException {
        try {
            final ManagedConnectionFactory mcf = createManagedConnectionFactory(jndiName, driverValue.getValue());
            final PoolConfiguration pc = createPoolConfig();
            final Pool pool = createPool(jndiName, mcf, pc);
            final ConnectionManager cm = createConnectionManager(jndiName, pool);
            sqlDataSource = (javax.sql.DataSource) mcf.createConnectionFactory(cm);


            org.jboss.jca.core.api.management.DataSource mgtDs = new org.jboss.jca.core.api.management.DataSource(false);// Register

View Full Code Here

Examples of org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration

     * @param tp The timeout parameters
     * @param vp The validation parameters
     * @return The configuration
     */
    protected PoolConfiguration createPoolConfiguration(final CommonPool pp, final CommonTimeOut tp, final CommonValidation vp) {
        final PoolConfiguration pc = new PoolConfiguration();


        if (pp != null) {
            if (pp.getMinPoolSize() != null)
                pc.setMinSize(pp.getMinPoolSize().intValue());


            if (pp.getMaxPoolSize() != null)
                pc.setMaxSize(pp.getMaxPoolSize().intValue());


            if (pp.isPrefill() != null)
                pc.setPrefill(pp.isPrefill());


            if (pp.isUseStrictMin() != null)
                pc.setStrictMin(pp.isUseStrictMin());
        }


        if (tp != null) {
            if (tp.getBlockingTimeoutMillis() != null)
                pc.setBlockingTimeout(tp.getBlockingTimeoutMillis().longValue());


            if (tp.getIdleTimeoutMinutes() != null)
                pc.setIdleTimeout(tp.getIdleTimeoutMinutes().longValue());
        }


        if (vp != null) {
            if (vp.isBackgroundValidation() != null)
                pc.setBackgroundValidation(vp.isBackgroundValidation().booleanValue());


            if (vp.getBackgroundValidationMinutes() != null)
                pc.setBackgroundValidationMinutes(vp.getBackgroundValidationMinutes().intValue());


            if (vp.isUseFastFail() != null)
                pc.setUseFastFail(vp.isUseFastFail());
        }


        return pc;
    }

View Full Code Here

0 1 2 3 4 5

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.