Examples of PoolableObjectFactory

org.apache.commons.pool.PoolableObjectFactory
An interface defining life-cycle methods for instances to be used in an {@link ObjectPool ObjectPool}.
By contract, when an {@link ObjectPool ObjectPool}delegates to a PoolableObjectFactory,
1. {@link #makeObject makeObject} is called whenever a new instance is needed.
2. {@link #activateObject activateObject} is invoked on every instance before it is returned from the pool.
3. {@link #passivateObject passivateObject} is invoked on every instance when it is returned to the pool.
4. {@link #destroyObject destroyObject} is invoked on every instance when it is being "dropped" from the pool (whether due to the response from {@link #validateObject validateObject}, or for reasons specific to the pool implementation.)
5. {@link #validateObject validateObject} is invoked in an implementation-specific fashion to determine if an instance is still valid to be returned by the pool. It will only be invoked on an {@link #activateObject "activated"}instance.
@author Rodney Waldhoff @version $Revision: 1.6 $ $Date: 2003/10/09 21:45:56 $ @see ObjectPool
org.datanucleus.store.rdbms.datasource.dbcp.pool.PoolableObjectFactory
An interface defining life-cycle methods for instances to be served by an {@link ObjectPool}.
By contract, when an {@link ObjectPool}delegates to a {@link PoolableObjectFactory},
1. {@link #makeObject makeObject}is called whenever a new instance is needed.
2. {@link #activateObject activateObject}is invoked on every instance that has been {@link #passivateObject passivated} before it is{@link ObjectPool#borrowObject borrowed} from the pool.
3. {@link #validateObject validateObject}is invoked on {@link #activateObject activated} instances to make surethey can be {@link ObjectPool#borrowObject borrowed} from the pool.validateObject may also be used to test an instance being {@link ObjectPool#returnObject returned} to the poolbefore it is {@link #passivateObject passivated}. It will only be invoked on an activated instance.
4. {@link #passivateObject passivateObject}is invoked on every instance when it is returned to the pool.
5. {@link #destroyObject destroyObject}is invoked on every instance when it is being "dropped" from the pool (whether due to the response from validateObject, or for reasons specific to the pool implementation.) There is no guarantee that the instance being destroyed will be considered active, passive or in a generally consistent state.
{@link PoolableObjectFactory} must be thread-safe. The only promisean {@link ObjectPool} makes is that the same instance of an object will notbe passed to more than one method of a PoolableObjectFactory at a time.
@see ObjectPool @author Rodney Waldhoff @author Sandy McArthur @version $Revision: 777748 $ $Date: 2009-05-22 20:00:44 -0400 (Fri, 22 May 2009) $ @since Pool 1.0

Examples of org.apache.commons.pool.PoolableObjectFactory

    GenericObjectPool objectPool = new GenericObjectPool();
    objectPool.setTestOnBorrow(false);
    objectPool.setTestOnReturn(false);
    objectPool.setTestWhileIdle(true);
    objectPool.setTimeBetweenEvictionRunsMillis(60 * 1000L);
    PoolableObjectFactory factory =
            new PoolableConnectionFactory(connectionFactory, objectPool, null, "SELECT 1", false, false);
    objectPool.setFactory(factory);
    delegate = new PoolingDataSource(objectPool);
  }

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory

                String nodeRootPath = rootPath+"/"+name;
                beanClassNodeRootPaths.put(beanClass, nodeRootPath);
            }
            
            // create JCR credentials session pool
            PoolableObjectFactory sessionFactory = new BasePoolableObjectFactory()
            {
                /* (non-Javadoc)
                 * @see org.apache.commons.pool.BasePoolableObjectFactory#passivateObject(java.lang.Object)
                 */
                public void passivateObject(Object obj) throws Exception

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory

     * Override this method to implement your on {@link org.apache.commons.pool.ObjectPool}.
     */
    public ObjectPool createConnectionPool(JdbcConnectionDescriptor jcd)
    {
        if (log.isDebugEnabled()) log.debug("createPool was called");
        PoolableObjectFactory pof = new ConPoolFactory(this, jcd);
        GenericObjectPool.Config conf = jcd.getConnectionPoolDescriptor().getObjectPoolConfig();
        return (ObjectPool)new GenericObjectPool(pof, conf);
    }

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory

                String nodeRootPath = rootPath+"/"+name;
                beanClassNodeRootPaths.put(beanClass, nodeRootPath);
            }
            
            // create JCR credentials session pool
            PoolableObjectFactory sessionFactory = new BasePoolableObjectFactory()
            {
                /* (non-Javadoc)
                 * @see org.apache.commons.pool.BasePoolableObjectFactory#passivateObject(java.lang.Object)
                 */
                public void passivateObject(Object obj) throws Exception

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory

        return new TestSuite(TestSoftReferenceObjectPool.class);
    }


    protected ObjectPool makeEmptyPool(int cap) {
        return new SoftReferenceObjectPool(
            new PoolableObjectFactory()  {
                int counter = 0;
                public Object makeObject() { return String.valueOf(counter++); }
                public void destroyObject(Object obj) { }
                public boolean validateObject(Object obj) { return true; }
                public void activateObject(Object obj) { }

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory




    public void testBorrowWithSometimesInvalidObjects() throws Exception {
        ObjectPool pool = new StackObjectPool(20);
        pool.setFactory(
            new PoolableObjectFactory() {
                // factory makes Integer objects
                int counter = 0;
                public Object makeObject() { return new Integer(counter++); }
                public void destroyObject(Object obj) { }
                public boolean validateObject(Object obj) {

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory


    private final List destroyed = new ArrayList();
    public void testReturnObjectDiscardOrder() throws Exception {
        // setup
        // We need a factory that tracks what was discarded.
        PoolableObjectFactory pof = new PoolableObjectFactory() {
            int i = 0;
            public Object makeObject() throws Exception {
                return new Integer(i++);
            }

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory

                String nodeRootPath = rootPath+"/"+name;
                beanClassNodeRootPaths.put(beanClass, nodeRootPath);
            }
            
            // create JCR credentials session pool
            PoolableObjectFactory sessionFactory = new BasePoolableObjectFactory()
            {
                /* (non-Javadoc)
                 * @see org.apache.commons.pool.BasePoolableObjectFactory#passivateObject(java.lang.Object)
                 */
                public void passivateObject(Object obj) throws Exception

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory

     * Override this method to implement your on {@link org.apache.commons.pool.ObjectPool}.
     */
    public ObjectPool createConnectionPool(JdbcConnectionDescriptor jcd)
    {
        if (log.isDebugEnabled()) log.debug("createPool was called");
        PoolableObjectFactory pof = new ConPoolFactory(this, jcd);
        GenericObjectPool.Config conf = jcd.getConnectionPoolDescriptor().getObjectPoolConfig();
        ObjectPool op = new GenericObjectPool(pof, conf);
        return op;
    }

View Full Code Here

Examples of org.apache.commons.pool.PoolableObjectFactory

  public HTableInterface getTable(String tableName) {
    GenericObjectPool pool = this.tablePools.get(tableName);
    
    if(pool == null){
      // lazy initialization of pool
      PoolableObjectFactory factory = new SolbaseHTableInterfaceFactory(config, tableName);
      pool = new GenericObjectPool(factory, this.maxActive);
    }
    try {
      HTableInterface table = (HTableInterface) pool.borrowObject();
      return table;

View Full Code Here

0 1 2 3 4

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.