poolobjectfactory.java

短信开发用于文件交换处理转发的类模块

package com.pub.dataframe;

import org.apache.commons.pool.PoolableObjectFactory;

//import com.pub.backserver.net.ClientNet;

public class PoolObjectFactory implements PoolableObjectFactory{
	
	public static String ip = "";
	public static int port;
	public static int timeout;
	
	public PoolObjectFactory(String _ip, int _port, int _timeout){
		ip = _ip;
		port = _port;
		timeout = _timeout;
	}
	
	public void activateObject(Object arg) throws Exception {
//		System.err.println("Activating Object " + arg);
	}
	
	public void destroyObject(Object arg) throws Exception {
//		System.err.println("Destroying Object " + arg);
	}

	public Object makeObject() throws Exception {
//		Object arg = String.valueOf(counter++);
//		System.err.println("Making Object " + arg);
//		ClientNet arg = new ClientNet(ip, port, timeout);
//		return arg;
		return null;
	}

	public void passivateObject(Object arg) throws Exception {
//		System.err.println("Passivating Object " + arg);
	}

	public boolean validateObject(Object arg) {
//		/* 以1/2的概率将对象判定为失效 */
//		boolean result = (Math.random() > 0.5);
//		System.err.println("Validating Object " + arg + " : " + result);
//		return result;
		return true;
	}
}