[jboss-svn-commits] JBL Code SVN: r6842 - labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db

[jboss-svn-commits at lists.jboss.org]

Author: daniel.brum at jboss.com
Date: 2006-10-16 17:24:49 -0400 (Mon, 16 Oct 2006)
New Revision: 6842

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/DBConnectionManager.java
Log:
Message Store changes

Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/DBConnectionManager.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/DBConnectionManager.java	2006-10-16 21:24:38 UTC (rev 6841)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/persistence/format/db/DBConnectionManager.java	2006-10-16 21:24:49 UTC (rev 6842)
@@ -21,7 +21,7 @@
 
 package org.jboss.internal.soa.esb.persistence.format.db;
 
-import java.io.IOException;
+
 import java.sql.Connection;
 
 import org.apache.commons.pool.ObjectPool;
@@ -31,13 +31,7 @@
 import org.apache.commons.dbcp.PoolableConnectionFactory;
 import org.apache.commons.dbcp.DriverManagerConnectionFactory;
 import org.jboss.soa.esb.common.Configuration;
-import org.jboss.soa.esb.common.Environment;
 
-import com.arjuna.common.internal.util.propertyservice.plugins.io.XMLFilePlugin;
-import com.arjuna.common.util.exceptions.LoadPropertiesException;
-import com.arjuna.common.util.propertyservice.PropertyManager;
-import com.arjuna.common.util.propertyservice.PropertyManagerFactory;
-
 /*
  * the DBConnectionManager class (singleton) is used by classes implenting the MessageStore interface
  * to obtain a connection to the persistence store database.
@@ -91,32 +85,25 @@
 	}
 		
 	private void init() throws Exception{
-//		String connectURL=propMgr.getProperty(Environment.MSG_STORE_DB_CONNECTION_URL);
-		String connectURL = Configuration.getStoreUrl();
-        //Class.forName(propMgr.getProperty(Environment.MSG_STORE_DB_JDBC_DRIVER));         
+
+		String connectURL = Configuration.getStoreUrl();       
 		Class.forName(Configuration.getStoreDriver());
         
 		ObjectPool connectionPool = new GenericObjectPool(null);		
 		
-//		ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(connectURL,
-//				propMgr.getProperty(Environment.MSG_STORE_DB_CONNECTION_USER), 
-//				propMgr.getProperty(Environment.MSG_STORE_DB_CONNECTION_PWD));		
 		ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(connectURL,
 				Configuration.getStoreUser(), Configuration.getStorePwd());
 		
 		@SuppressWarnings("unused")
-//		PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(connectionFactory,
-//				connectionPool,null,propMgr.getProperty(Environment.MSG_STORE_DB_VALIDATE_SQL),false,true);
 		PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(connectionFactory,
 				connectionPool,null,Configuration.getStoreValidateSql(),false,true);
 		
-//		int poolSize = Integer.valueOf(propMgr.getProperty(Environment.MSG_STORE_DB_POOL_SIZE)).intValue();
 		int poolSize = Integer.valueOf(Configuration.getStorePoolSize()).intValue();
 		
 		//add the max # of connections into the pool
 		for (int i=0 ; i<poolSize ; i++) {
 			   try {
-				System.out.println(this.getClass().getSimpleName() + ": adding connection # " + (i+1) + " to the pool...");				
+				//System.out.println(this.getClass().getSimpleName() + ": adding connection # " + (i+1) + " to the pool...");				
 				connectionPool.addObject();
 			} catch (Exception e) {				
 				e.printStackTrace();