[jboss-svn-commits] JBL Code SVN: r5512 - in labs/jbossesb/branches/refactor/product/core/common: src/org/jboss/soa/esb/connection src/org/jboss/soa/esb/connection/exception tests tests/src/org/jboss/soa/esb/connection
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sun Aug 6 11:33:09 EDT 2006
Author: arvinder
Date: 2006-08-06 11:32:52 -0400 (Sun, 06 Aug 2006)
New Revision: 5512
Added:
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/exception/ESBConnectionException.java
labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/HashPasswordDecoder.java
labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/TestConnectionPool.java
labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/TestPasswordDecoder.java
Removed:
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/exception/ConnectionException.java
labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/AbandonedConnectionFuncTest.java
labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/ConnectionPoolFuncTest.java
labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderFuncTest.java
labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderTestImpl.java
Modified:
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/AbandonedConnectionTimerTask.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionFactory.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPool.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPoolFactory.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionProperties.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionWrapper.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DefaultConnectionPoolImpl.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DriverConnectionFactory.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/FreeConnectionPoolResources.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PasswordDecoder.java
labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PoolDataSource.java
labs/jbossesb/branches/refactor/product/core/common/tests/build.xml
Log:
Name change EsbUtil to Util
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/AbandonedConnectionTimerTask.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/AbandonedConnectionTimerTask.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/AbandonedConnectionTimerTask.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -26,7 +26,7 @@
/**
* Timer task which will run at scheduled times based on the property set by the user.
* This task will remove all unused connections which have elapsed a certain period of time
- * @author MohitK
+ * User: MohitK
* Date: Jul 26, 2006
*/
public class AbandonedConnectionTimerTask extends TimerTask {
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionFactory.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionFactory.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionFactory.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -25,9 +25,8 @@
import java.sql.SQLException;
/**
- * Factory interface for creating connections based on different sources such as Driver, DriverManager or any
- * third party implementation
- * @author MohitK
+ * Factory interface for creating connections based on different sources such as DataSource, DriverConnection
+ * User: MohitK
* Date: Jul 18, 2006
*/
public interface ConnectionFactory {
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPool.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPool.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPool.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -21,25 +21,23 @@
*/
package org.jboss.soa.esb.connection;
-import org.jboss.soa.esb.connection.exception.ConnectionException;
+import org.jboss.soa.esb.connection.exception.ESBConnectionException;
import java.sql.Connection;
import java.sql.SQLException;
/**
- * Interface that needs to be implemented to provide pool of connections.
- * @see DefaultConnectionPoolImpl
- * Default implementation of Connection Pool
- * @author MohitK
+ * TODO
+ * User: MohitK
* Date: Jul 18, 2006
*/
public interface ConnectionPool {
/**
* This method is used to create the connection pool and keep it ready
* @param prop Properties for the connection pool including connection properties
- * @throws ConnectionException
+ * @throws ESBConnectionException
*/
- public void createPool(ConnectionProperties prop) throws ConnectionException;
+ public void createPool(ConnectionProperties prop) throws ESBConnectionException;
/**
* This method is called whenever a connection is needed from the pool.
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPoolFactory.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPoolFactory.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionPoolFactory.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -21,44 +21,35 @@
*/
package org.jboss.soa.esb.connection;
-import org.apache.log4j.Logger;
-import org.jboss.soa.esb.connection.exception.ConnectionException;
+import org.jboss.soa.esb.connection.exception.ESBConnectionException;
/**
- * Factory class which creates a connection pool. The factory also creates a JVM Shutdown hook which is called when
- * JVM is shutting down which indirectly calls @link ConnectionPool#releasePool
- *
- * @author MohitK
- * Date: Jul 19, 2006
+ * Factory class to create the connection pool.
+ * User: MohitK
+ * Date: Jul 19, 2006
*/
public class ConnectionPoolFactory {
-
- private static Logger Log = Logger.getLogger(ConnectionPoolFactory.class);
-
/**
* Factory method to create and return a connection pool based on the property set for the connection pool
* implementation. The factory also registers a shut down hook with the JVM so that the connections in the pool
* are closed and released with causing connections leaks.
- *
* @param connProperties Properties for the connection pool
* @return Connection Pool
- * @throws ConnectionException
+ * @throws ESBConnectionException
*/
- public static ConnectionPool createPool(ConnectionProperties connProperties) throws ConnectionException {
+ public static ConnectionPool createPool(ConnectionProperties connProperties) throws ESBConnectionException {
String connectionPoolClassName = connProperties.getConnectionPoolClass();
try {
- ConnectionPool pool = (ConnectionPool) Class.forName(connectionPoolClassName).newInstance();
+ ConnectionPool pool = (ConnectionPool)Class.forName(connectionPoolClassName).newInstance();
pool.createPool(connProperties);
FreeConnectionPoolResources freeResourcesThread = new FreeConnectionPoolResources(pool);
Runtime.getRuntime().addShutdownHook(freeResourcesThread);
return pool;
- } catch (ConnectionException e) {
- Log.error("ConnectionPoolFactory: Error in creating Connection Pool", e);
- throw e;
- } catch (Throwable t){
- Log.error("ConnectionPoolFactory: Error in Connection Pool", t);
- throw new ConnectionException(t);
+ } catch (Throwable t) {
+ System.err.println("ConnectionPoolFactory: Error in Connection Pool");
+ System.err.println(t);
+ throw new ESBConnectionException(t);
}
}
}
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionProperties.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionProperties.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionProperties.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -21,23 +21,18 @@
*/
package org.jboss.soa.esb.connection;
-import org.apache.log4j.Logger;
-
import java.util.Properties;
/**
- * Connection Property class which stores all connection and connection pool properties. It keeps the properties ready
+ * Connection Property class which stores all connection and connection pool properties. It keeps the peroperties ready
* so that is can be used by the pool and connection factory
- *
- * @author MohitK
- * Date: Jul 18, 2006
+ * User: MohitK
+ * Date: Jul 18, 2006
*/
public class ConnectionProperties {
- private static Logger Log = Logger.getLogger(ConnectionProperties.class);
+ private Properties _connectionProperties;
- private Properties m_oConnectionProperties;
-
public static final String DRIVER_CLASSNAME = "driver-class";
public static final String CONNECTION_URL = "connection-url";
public static final String USERNAME = "user-name";
@@ -52,18 +47,18 @@
public static final String ABANDONED_CONNECTION_TIMEOUT = "abandoned-connection-timeout";
public static final String ABANDONED_CONNECTION_CHECK_INTERVAL = "abandoned-connection-time-interval";
- private boolean m_bAutoCommit;
- private Integer m_iIsolationLvl;
- private int m_iMinPoolSize;
- private int m_iMaxPoolSize;
- private long m_lConnBlockTime;
- private String m_sConnectionPoolClass;
- private String m_sUser;
- private String m_sPassword;
- private String m_sConnectionUrl;
- private long m_lAbandonedConnectionTimeout;
- private long m_lAbandonedConnectionCheckInterval;
- private String m_sDriverClassName;
+ private boolean _autoCommit;
+ private Integer _isolationLvl;
+ private int _minPoolSize;
+ private int _maxPoolSize;
+ private long _connBlockTime;
+ private String _connectionPoolClass;
+ private String _user;
+ private String _password;
+ private String _connectionUrl;
+ private long _abandonedConnectionTimeout;
+ private long _abandonedConnectionCheckInterval;
+ private String _driverClassName;
public static final String DEFAULT_MIN_POOL_SIZE = "5";
@@ -74,7 +69,7 @@
public static final String DEFAULT_ABANDONED_CONNECTION_CHECK_INTERVAL = "30000";
public ConnectionProperties(Properties connectionProperties) {
- this.m_oConnectionProperties = connectionProperties;
+ this._connectionProperties = connectionProperties;
setDriverClassName();
setConnectionUrl();
setUser();
@@ -90,162 +85,164 @@
}
private void setDriverClassName() {
- m_sDriverClassName = m_oConnectionProperties.getProperty(DRIVER_CLASSNAME);
- if (m_sDriverClassName == null) {
- m_sDriverClassName = System.getProperty(DRIVER_CLASSNAME);
+ _driverClassName = _connectionProperties.getProperty(DRIVER_CLASSNAME);
+ if (_driverClassName == null) {
+ _driverClassName = System.getProperty(DRIVER_CLASSNAME);
}
}
protected String getDriverClassName() {
- return m_sDriverClassName;
+ return _driverClassName;
}
protected String getConnectionUrl() {
- return m_sConnectionUrl;
+ return _connectionUrl;
}
private void setConnectionUrl() {
- m_sConnectionUrl = m_oConnectionProperties.getProperty(CONNECTION_URL);
- if (m_sConnectionUrl == null) {
- m_sConnectionUrl = System.getProperty(CONNECTION_URL);
+ _connectionUrl = _connectionProperties.getProperty(CONNECTION_URL);
+ if (_connectionUrl == null) {
+ _connectionUrl = System.getProperty(CONNECTION_URL);
}
}
protected boolean getAutoCommit() {
- return m_bAutoCommit;
+ return _autoCommit;
}
protected Integer getIsolationLevel() {
- return m_iIsolationLvl;
+ return _isolationLvl;
}
private void setIsolationLevel() {
- String isolation = (String) m_oConnectionProperties.get(ISOLATION_LEVEL);
+ String isolation = (String) _connectionProperties.get(ISOLATION_LEVEL);
if (isolation == null) {
isolation = System.getProperty(ISOLATION_LEVEL);
}
- this.m_iIsolationLvl = (isolation != null) ? new Integer(isolation) : null;
+ this._isolationLvl = (isolation != null) ? new Integer(isolation) : null;
}
protected int getMinPoolSize() {
- return m_iMinPoolSize;
+ return _minPoolSize;
}
protected int getMaxPoolSize() {
- return m_iMaxPoolSize;
+ return _maxPoolSize;
}
private void setMinPoolSize() {
- String strPoolSize = m_oConnectionProperties.getProperty(MIN_POOL_SIZE);
+ String strPoolSize = _connectionProperties.getProperty(MIN_POOL_SIZE);
if (strPoolSize == null) {
strPoolSize = System.getProperty(MIN_POOL_SIZE, DEFAULT_MIN_POOL_SIZE);
- this.m_iMinPoolSize = Integer.parseInt(strPoolSize);
+ this._minPoolSize = Integer.parseInt(strPoolSize);
}
}
private void setMaxPoolSize() {
- String strPoolSize = (String) m_oConnectionProperties.get(MAX_POOL_SIZE);
+ String strPoolSize = (String) _connectionProperties.get(MAX_POOL_SIZE);
if (strPoolSize == null) {
strPoolSize = System.getProperty(MAX_POOL_SIZE, DEFAULT_MAX_POOL_SIZE);
- this.m_iMaxPoolSize = Integer.parseInt(strPoolSize);
+ this._maxPoolSize = Integer.parseInt(strPoolSize);
}
}
private void setBlockingConnectionTime() {
- String strBlockTimeMillis = (String) m_oConnectionProperties.get(BLOCKING_CONNECTION_TIME);
+ String strBlockTimeMillis = (String) _connectionProperties.get(BLOCKING_CONNECTION_TIME);
if (strBlockTimeMillis == null) {
strBlockTimeMillis = System.getProperty(BLOCKING_CONNECTION_TIME, DEFAULT_CONN_BLOCK_TIME_MILLIS);
- this.m_lConnBlockTime = Integer.parseInt(strBlockTimeMillis);
+ this._connBlockTime = Integer.parseInt(strBlockTimeMillis);
}
}
protected long getConnectionBlockTimeInMillis() {
- return m_lConnBlockTime;
+ return _connBlockTime;
}
private void setAutoCommit() {
- String autoCommit = (String) m_oConnectionProperties.get(AUTO_COMMIT);
+ String autoCommit = (String) _connectionProperties.get(AUTO_COMMIT);
if (autoCommit == null || autoCommit.equals("false")) {
- m_bAutoCommit = Boolean.FALSE;
+ _autoCommit = Boolean.FALSE;
} else {
- m_bAutoCommit = Boolean.TRUE;
+ _autoCommit = Boolean.TRUE;
}
}
private void setConnectionPoolClass() {
- m_sConnectionPoolClass = m_oConnectionProperties.getProperty(CONNECTION_POOL_CLASS);
- if (m_sConnectionPoolClass == null) {
- m_sConnectionPoolClass = System.getProperty(CONNECTION_POOL_CLASS, DEFAULT_CONNECTION_POOL_CLASS);
+ _connectionPoolClass = _connectionProperties.getProperty(CONNECTION_POOL_CLASS);
+ if (_connectionPoolClass == null) {
+ _connectionPoolClass = System.getProperty(CONNECTION_POOL_CLASS, DEFAULT_CONNECTION_POOL_CLASS);
}
}
protected String getUser() {
- return m_sUser;
+ return _user;
}
public void setUser() {
- this.m_sUser = m_oConnectionProperties.getProperty(USERNAME);
- if (m_sUser == null) {
- m_sUser = System.getProperty(USERNAME);
+ this._user = _connectionProperties.getProperty(USERNAME);
+ if (_user == null) {
+ _user = System.getProperty(USERNAME);
}
}
protected String getPassword() {
- return m_sPassword;
+ return _password;
}
protected void setPassword() {
- this.m_sPassword = m_oConnectionProperties.getProperty(PASSWORD);
- if (m_sPassword == null) {
- m_sPassword = System.getProperty(PASSWORD);
+ this._password = _connectionProperties.getProperty(PASSWORD);
+ if (_password == null) {
+ _password = System.getProperty(PASSWORD);
}
- String strPasswordDecoder = m_oConnectionProperties.getProperty(PASSWORD_DECODER);
+ String strPasswordDecoder = _connectionProperties.getProperty(PASSWORD_DECODER);
if (strPasswordDecoder == null) {
strPasswordDecoder = System.getProperty(PASSWORD_DECODER);
}
if (strPasswordDecoder != null) {
try {
PasswordDecoder decoder = (PasswordDecoder) Class.forName(strPasswordDecoder).newInstance();
- this.m_sPassword = decoder.decode(m_sPassword);
+ this._password = decoder.decode(_password);
} catch (InstantiationException e) {
- Log.error("Error in creating instance of Password Decoder Class:-" + strPasswordDecoder,e);
+ System.err.println("Error in creating instance of Password Decoder Class:-" + strPasswordDecoder);
+ System.err.println(e);
} catch (IllegalAccessException e) {
- Log.error("Error in creating instance of Password Decoder Class:-" + strPasswordDecoder,e);
+ System.err.println("Error in creating instance of Password Decoder Class:-" + strPasswordDecoder);
+ System.err.println(e);
} catch (ClassNotFoundException e) {
- Log.error("Password Decoder Class:-" + strPasswordDecoder + " not found in Classpath");
- Log.error("Please check the property:-" + PASSWORD_DECODER);
- Log.error(e);
+ System.err.println("Password Decoder Class:-" + strPasswordDecoder + " not found in Classpath");
+ System.err.println("Please check the property:-" + PASSWORD_DECODER);
+ System.err.println(e);
}
}
}
protected String getConnectionPoolClass() {
- return m_sConnectionPoolClass;
+ return _connectionPoolClass;
}
private void setAbandonedConnectionTimeOut() {
- String strAbandonedConnectionTimeout = m_oConnectionProperties.getProperty(ABANDONED_CONNECTION_TIMEOUT);
+ String strAbandonedConnectionTimeout = _connectionProperties.getProperty(ABANDONED_CONNECTION_TIMEOUT);
if (strAbandonedConnectionTimeout == null) {
strAbandonedConnectionTimeout = System.getProperty(ABANDONED_CONNECTION_TIMEOUT, DEFAULT_ABANDONED_CONNECTION_TIMEOUT);
}
- this.m_lAbandonedConnectionTimeout = Long.parseLong(strAbandonedConnectionTimeout);
+ this._abandonedConnectionTimeout = Long.parseLong(strAbandonedConnectionTimeout);
}
private void setAbandonedConnectionCheckInterval() {
- String strAbandonedConnectionCheckInterval = m_oConnectionProperties.getProperty(ABANDONED_CONNECTION_CHECK_INTERVAL);
+ String strAbandonedConnectionCheckInterval = _connectionProperties.getProperty(ABANDONED_CONNECTION_CHECK_INTERVAL);
if (strAbandonedConnectionCheckInterval == null || strAbandonedConnectionCheckInterval.trim().length() == 0) {
strAbandonedConnectionCheckInterval = System.getProperty(ABANDONED_CONNECTION_CHECK_INTERVAL, DEFAULT_ABANDONED_CONNECTION_CHECK_INTERVAL);
}
- this.m_lAbandonedConnectionCheckInterval = Long.parseLong(strAbandonedConnectionCheckInterval);
+ this._abandonedConnectionCheckInterval = Long.parseLong(strAbandonedConnectionCheckInterval);
}
- protected long getAbandonedConnectionTimeOut() {
- return this.m_lAbandonedConnectionTimeout;
+ protected long getAbandonedConnectionTimeOut(){
+ return this._abandonedConnectionTimeout;
}
- protected long getAbandonedConnectionCheckInterval() {
- return this.m_lAbandonedConnectionCheckInterval;
+ protected long getAbandonedConnectionCheckInterval(){
+ return this._abandonedConnectionCheckInterval;
}
}
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionWrapper.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionWrapper.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/ConnectionWrapper.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -26,7 +26,7 @@
/**
* Wrapper class which encapsulates @link Connection
- * @author MohitK
+ * User: MohitK
* Date: Jul 18, 2006
*/
public class ConnectionWrapper implements Connection {
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DefaultConnectionPoolImpl.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DefaultConnectionPoolImpl.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DefaultConnectionPoolImpl.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -21,8 +21,7 @@
*/
package org.jboss.soa.esb.connection;
-import org.apache.log4j.Logger;
-import org.jboss.soa.esb.connection.exception.ConnectionException;
+import org.jboss.soa.esb.connection.exception.ESBConnectionException;
import java.sql.Connection;
import java.sql.Driver;
@@ -35,25 +34,23 @@
import java.util.concurrent.ConcurrentHashMap;
/**
- * Default connection pool implementation class when none is specified by the user in @link ConnectionProperties
- *
- * @author MohitK
- * Date: Jul 18, 2006
+ * Default connection pool implementation class when there is none specified by the user in @link ConnectionProperties
+ * User: MohitK
+ * Date: Jul 18, 2006
*/
public class DefaultConnectionPoolImpl implements ConnectionPool {
- private static Logger Log = Logger.getLogger(DefaultConnectionPoolImpl.class);
-
private final Stack<ConnectionWrapper> m_oConnectionStack = new Stack<ConnectionWrapper>();
private final ConcurrentHashMap<String, ConnectionWrapper> m_oUsedConnectionMap = new ConcurrentHashMap<String, ConnectionWrapper>();
private int m_iConnCountInPool;
private ConnectionProperties m_oConnProperties;
- private ConnectionFactory m_oConnectionFactory;
+ private ConnectionFactory _connectionFactory;
/**
- * @see ConnectionPool#createPool(ConnectionProperties)
+ * @see org.jboss.soa.esb.connection.ConnectionPool#createPool(ConnectionProperties)
+ *
*/
- public void createPool(ConnectionProperties prop) throws ConnectionException {
+ public void createPool(ConnectionProperties prop) throws ESBConnectionException {
this.m_oConnProperties = prop;
try {
initPool();
@@ -61,22 +58,21 @@
Timer abandonedTimer = new Timer(":AbandonedConnectionPoolScheduler:@" + this.toString(), true);
abandonedTimer.schedule(abandonedConnTask, prop.getAbandonedConnectionCheckInterval(), prop.getAbandonedConnectionCheckInterval());
} catch (SQLException e) {
- Log.error("DefaultConnectionPoolImpl: Error in creating Connection Pool",e);
- throw new ConnectionException("DefaultConnectionPoolImpl: Error in creating Connection Pool\n Reason:-" + e.getMessage(), e);
+ throw new ESBConnectionException("DefaultConnectionPoolImpl: Error in creating Connection Pool", e);
}
}
private void initPool() throws SQLException {
- if (m_oConnectionFactory == null) {
+ if (_connectionFactory == null) {
Properties properties = new Properties();
properties.put("user", m_oConnProperties.getUser());
properties.put("password", m_oConnProperties.getPassword());
- m_oConnectionFactory = new DriverConnectionFactory(getDriver(m_oConnProperties.getDriverClassName()), m_oConnProperties.getConnectionUrl(), properties);
+ _connectionFactory = new DriverConnectionFactory(getDriver(m_oConnProperties.getDriverClassName()), m_oConnProperties.getConnectionUrl(), properties);
}
while (m_iConnCountInPool < m_oConnProperties.getMinPoolSize()) {
synchronized (m_oConnectionStack) {
- m_oConnectionStack.add(new ConnectionWrapper(m_oConnectionFactory.createConnection(), this));
+ m_oConnectionStack.add(new ConnectionWrapper(_connectionFactory.createConnection(), this));
m_iConnCountInPool++;
}
}
@@ -87,7 +83,8 @@
try {
Class.forName(driverClassName);
} catch (Throwable e) {
- Log.error("DefaultConnectionPoolImpl: Error in loading class " + driverClassName + " to create connection pool", e);
+ System.err.println("DefaultConnectionPoolImpl: Error in loading class " + driverClassName + " to create connection pool");
+ System.err.println(e);
throw new SQLException("DefaultConnectionPoolImpl: Error in loading class " + driverClassName + " to create connection pool");
}
return DriverManager.getDriver(m_oConnProperties.getConnectionUrl());
@@ -96,7 +93,8 @@
}
/**
- * @see ConnectionPool#getConnection()
+ * @see org.jboss.soa.esb.connection.ConnectionPool#getConnection()
+ *
*/
public synchronized Connection getConnection() throws SQLException {
ConnectionWrapper newPoolConnection;
@@ -104,7 +102,7 @@
newPoolConnection = m_oConnectionStack.pop();
m_oUsedConnectionMap.put(newPoolConnection.getName(), newPoolConnection);
} else if (m_iConnCountInPool < m_oConnProperties.getMaxPoolSize()) {
- newPoolConnection = new ConnectionWrapper(m_oConnectionFactory.createConnection(), this);
+ newPoolConnection = new ConnectionWrapper(_connectionFactory.createConnection(), this);
m_oUsedConnectionMap.put(newPoolConnection.getName(), newPoolConnection);
m_iConnCountInPool++;
} else {
@@ -162,7 +160,8 @@
m_oUsedConnectionMap.remove(name);
}
} catch (SQLException e) {
- Log.error("DefaultConnectionPoolImpl: Error in closing physical Connection", e);
+ System.err.println("DefaultConnectionPoolImpl: Error in closing physical Connection");
+ System.err.println(e);
}
}
@@ -173,6 +172,7 @@
/**
* This method will release all abandoned connections from the pool.
+ *
*/
protected synchronized void releaseAbandonedConnections() {
@@ -183,7 +183,7 @@
long currentTime = System.currentTimeMillis();
if ((currentTime - activedTime) > m_oConnProperties.getAbandonedConnectionTimeOut()) {
try {
- Log.info("Removing abandoned Connection:-" + connectionWrapper);
+ System.out.println("Removing abandoned Connection:-" + connectionWrapper);
Connection actualConnection = connectionWrapper.getActualConnection();
m_oUsedConnectionMap.remove(connectionWrapper.getName());
connectionWrapper.setOriginalConnection(null);
@@ -193,7 +193,8 @@
m_oConnectionStack.push(connectionWrapper);
}
} catch (SQLException e) {
- Log.error("Error in releasing abandoned connection from Pool", e);
+ System.err.println("Error in releasing abandoned connection from Pool");
+ e.printStackTrace(System.err);
}
}
}
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DriverConnectionFactory.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DriverConnectionFactory.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/DriverConnectionFactory.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -22,13 +22,13 @@
package org.jboss.soa.esb.connection;
import java.sql.Connection;
+import java.sql.SQLException;
import java.sql.Driver;
-import java.sql.SQLException;
import java.util.Properties;
/**
* Driver implementation of Connection Factory
- * @author MohitK
+ * User: MohitK
* Date: Jul 18, 2006
*/
public class DriverConnectionFactory implements ConnectionFactory{
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/FreeConnectionPoolResources.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/FreeConnectionPoolResources.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/FreeConnectionPoolResources.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -21,20 +21,14 @@
*/
package org.jboss.soa.esb.connection;
-import org.apache.log4j.Logger;
-
/**
- * Shutdown Hook into the JVM. The class will be invoked by the JVM when JVM is shutting down.
+ * Shutdown Hook into the JVM. The class will be invoked by the JVM when the JVM is shutting down.
* Used to free connection resources and destroy the connection pool.
- * This class is will guarantee closing of all connections rather than depending on finalize method.
- *
- * @author MohitK
+ * User: MohitK
* Date: Jul 22, 2006
*/
public class FreeConnectionPoolResources extends Thread {
- private static Logger Log = Logger.getLogger(FreeConnectionPoolResources.class);
-
ConnectionPool pool;
public FreeConnectionPoolResources(ConnectionPool pool) {
@@ -45,7 +39,7 @@
try {
pool.releasePool();
} catch (Exception e) {
- Log.error("Error in freeing resources");
+ System.err.println("Error in freeing resources");
}
}
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PasswordDecoder.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PasswordDecoder.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PasswordDecoder.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -24,7 +24,7 @@
/**
* Interface to be implemented by classes when they need to return the DB password for the connection by using their own
* algorithm. Called by the connection pool
- * @author MohitK
+ * User: MohitK
* Date: Jul 21, 2006
*/
public interface PasswordDecoder {
Modified: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PoolDataSource.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PoolDataSource.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/PoolDataSource.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -21,8 +21,7 @@
*/
package org.jboss.soa.esb.connection;
-import org.apache.log4j.Logger;
-import org.jboss.soa.esb.connection.exception.ConnectionException;
+import org.jboss.soa.esb.connection.exception.ESBConnectionException;
import javax.sql.DataSource;
import java.io.PrintWriter;
@@ -32,41 +31,39 @@
/**
* Implementation if Datasource for getting connections from pool.
- * @author MohitK
+ * User: MohitK
* Date: Jul 19, 2006
*/
public class PoolDataSource implements DataSource {
- private static Logger Log = Logger.getLogger(PoolDataSource.class);
+ private ConnectionPool _pool;
+ private PrintWriter _logWriter = new PrintWriter(System.out);
+ private int _loginTimeOut;
+ private final Properties _connProps = new Properties();
+ ConnectionProperties _connectionProperties;
- private ConnectionPool m_oPool;
- private PrintWriter m_oLogWriter = new PrintWriter(System.out);
- private int m_iLoginTimeOut;
- private final Properties m_oConnProps = new Properties();
- ConnectionProperties m_oConnectionProperties;
-
private synchronized ConnectionPool createConnectionPool() throws SQLException {
- if (m_oPool == null) {
+ if (_pool == null) {
try {
- if (m_oConnProps != null) {
- m_oConnectionProperties = new ConnectionProperties(m_oConnProps);
- m_oPool = ConnectionPoolFactory.createPool(m_oConnectionProperties);
+ if (_connProps != null) {
+ _connectionProperties = new ConnectionProperties(_connProps);
+ _pool = ConnectionPoolFactory.createPool(_connectionProperties);
}
- } catch (ConnectionException e) {
- Log.error("PoolDataSource: Error in creating Connection Pool",e);
- throw new SQLException(e.getMessage());
+ } catch (ESBConnectionException e) {
+ _logWriter.println("PoolDataSource: Error in creating Connection Pool");
+ throw new SQLException("Error in Connection Pool Creation");
}
}
- return m_oPool;
+ return _pool;
}
public Properties getConnectionProperties() {
- return m_oConnProps;
+ return _connProps;
}
public void setConnectionProperties(Properties _connProperties) {
- m_oConnProps.putAll(_connProperties);
+ _connProps.putAll(_connProperties);
}
/**
@@ -80,9 +77,9 @@
* @see javax.sql.DataSource#getConnection(String, String)
*/
public Connection getConnection(String username, String password) throws SQLException {
- synchronized(m_oConnProps){
- m_oConnProps.setProperty(ConnectionProperties.USERNAME, username);
- m_oConnProps.setProperty(ConnectionProperties.PASSWORD, password);
+ synchronized(_connProps){
+ _connProps.setProperty(ConnectionProperties.USERNAME, username);
+ _connProps.setProperty(ConnectionProperties.PASSWORD, password);
}
return createConnectionPool().getConnection();
}
@@ -97,20 +94,20 @@
* @see javax.sql.DataSource#setLogWriter(java.io.PrintWriter)
*/
public void setLogWriter(PrintWriter out) throws SQLException {
- this.m_oLogWriter = out;
+ this._logWriter = out;
}
/**
* @see javax.sql.DataSource#setLoginTimeout(int)
*/
public void setLoginTimeout(int seconds) throws SQLException {
- this.m_iLoginTimeOut = seconds;
+ this._loginTimeOut = seconds;
}
/**
* @see javax.sql.DataSource#getLoginTimeout()
*/
public int getLoginTimeout() throws SQLException {
- return m_iLoginTimeOut;
+ return _loginTimeOut;
}
}
Deleted: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/exception/ConnectionException.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/exception/ConnectionException.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/exception/ConnectionException.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -1,45 +0,0 @@
-/*
-* JBoss, Home of Professional Open Source
-* Copyright 2006, JBoss Inc., and individual contributors as indicated
-* by the @authors tag. See the copyright.txt in the distribution for a
-* full listing of individual contributors.
-*
-* This is free software; you can redistribute it and/or modify it
-* under the terms of the GNU Lesser General Public License as
-* published by the Free Software Foundation; either version 2.1 of
-* the License, or (at your option) any later version.
-*
-* This software is distributed in the hope that it will be useful,
-* but WITHOUT ANY WARRANTY; without even the implied warranty of
-* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-* Lesser General Public License for more details.
-*
-* You should have received a copy of the GNU Lesser General Public
-* License along with this software; if not, write to the Free
-* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
-* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
-*/
-package org.jboss.soa.esb.connection.exception;
-
-/**
- * This exception is thrown when Connection Pool fails to initialize
- * @author MohitK
- * Date: Jul 21, 2006
- */
-public class ConnectionException extends Exception{
- public ConnectionException() {
- super();
- }
-
- public ConnectionException(String message) {
- super(message);
- }
-
- public ConnectionException(String message, Throwable cause) {
- super(message, cause);
- }
-
- public ConnectionException(Throwable cause) {
- super(cause);
- }
-}
Copied: labs/jbossesb/branches/refactor/product/core/common/src/org/jboss/soa/esb/connection/exception/ESBConnectionException.java (from rev 5508, labs/jbossesb/trunk/product/core/common/src/org/jboss/soa/esb/connection/exception/ESBConnectionException.java)
Modified: labs/jbossesb/branches/refactor/product/core/common/tests/build.xml
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/tests/build.xml 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/tests/build.xml 2006-08-06 15:32:52 UTC (rev 5512)
@@ -92,6 +92,7 @@
<batchtest todir="${org.jboss.esb.tests.report.dir}">
<fileset dir="${org.jboss.esb.module.tests.src.dir}">
<include name="**/**UnitTest.java"/>
+ <exclude name="**/connection/**"/>
<include name="**/**FuncTest.java"/>
</fileset>
</batchtest>
Deleted: labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/AbandonedConnectionFuncTest.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/AbandonedConnectionFuncTest.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/AbandonedConnectionFuncTest.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -1,71 +0,0 @@
-/*
-* JBoss, Home of Professional Open Source
-* Copyright 2006, JBoss Inc., and individual contributors as indicated
-* by the @authors tag. See the copyright.txt in the distribution for a
-* full listing of individual contributors.
-*
-* This is free software; you can redistribute it and/or modify it
-* under the terms of the GNU Lesser General Public License as
-* published by the Free Software Foundation; either version 2.1 of
-* the License, or (at your option) any later version.
-*
-* This software is distributed in the hope that it will be useful,
-* but WITHOUT ANY WARRANTY; without even the implied warranty of
-* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-* Lesser General Public License for more details.
-*
-* You should have received a copy of the GNU Lesser General Public
-* License along with this software; if not, write to the Free
-* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
-* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
-*/
-package org.jboss.soa.esb.connection;
-
-import junit.framework.TestCase;
-
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-import java.util.Properties;
-
-/**
- * TODO
- * User: MohitK
- * Date: Aug 3, 2006
- */
-public class AbandonedConnectionFuncTest extends TestCase {
-
- Properties properties = new Properties();
-
- protected void setUp() throws Exception {
- properties.put(ConnectionProperties.DRIVER_CLASSNAME, "com.mysql.jdbc.Driver");
- properties.put(ConnectionProperties.CONNECTION_URL, "jdbc:mysql://localhost/rosetta");
- properties.put(ConnectionProperties.USERNAME, "rosetta");
- properties.put(ConnectionProperties.PASSWORD, "rosetta");
- properties.put(ConnectionProperties.ABANDONED_CONNECTION_CHECK_INTERVAL, "30000");
- }
-
-
- public void testAbandonedConnections() {
- PoolDataSource ds = new PoolDataSource();
- ds.setConnectionProperties(properties);
- Connection con1 = null;
- Connection con2 = null;
- Connection con3 = null;
- try {
- con1 = ds.getConnection();
- con2 = ds.getConnection();
- try {
- Thread.sleep(70000);
- } catch (InterruptedException e) {
- //Do nothing
- }
- con1.createStatement();
- } catch (SQLException e) {
- e.printStackTrace();
- assertTrue(true);
- }
- }
-
-}
Deleted: labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/ConnectionPoolFuncTest.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/ConnectionPoolFuncTest.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/ConnectionPoolFuncTest.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -1,84 +0,0 @@
-/*
-* JBoss, Home of Professional Open Source
-* Copyright 2006, JBoss Inc., and individual contributors as indicated
-* by the @authors tag. See the copyright.txt in the distribution for a
-* full listing of individual contributors.
-*
-* This is free software; you can redistribute it and/or modify it
-* under the terms of the GNU Lesser General Public License as
-* published by the Free Software Foundation; either version 2.1 of
-* the License, or (at your option) any later version.
-*
-* This software is distributed in the hope that it will be useful,
-* but WITHOUT ANY WARRANTY; without even the implied warranty of
-* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-* Lesser General Public License for more details.
-*
-* You should have received a copy of the GNU Lesser General Public
-* License along with this software; if not, write to the Free
-* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
-* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
-*/
-package org.jboss.soa.esb.connection;
-
-import junit.framework.TestCase;
-import org.jboss.soa.esb.connection.ConnectionProperties;
-import org.jboss.soa.esb.connection.PoolDataSource;
-
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-import java.util.Properties;
-
-/**
- * TODO
- * @author MohitK
- * Date: Jul 22, 2006
- */
-public class ConnectionPoolFuncTest extends TestCase {
-
- Properties properties = new Properties();
-
- protected void setUp() throws Exception {
- properties.put(ConnectionProperties.DRIVER_CLASSNAME, "com.mysql.jdbc.Driver");
- properties.put(ConnectionProperties.CONNECTION_URL, "jdbc:mysql://localhost/rosetta");
- properties.put(ConnectionProperties.USERNAME, "rosetta");
- properties.put(ConnectionProperties.PASSWORD, "rosetta");
- }
-
-
- public void testConnectionPool() {
- PoolDataSource ds = new PoolDataSource();
- ds.setConnectionProperties(properties);
- Connection con = null;
- Statement stat = null;
- try {
- con = ds.getConnection();
- stat = con.createStatement();
- ResultSet rs = stat.executeQuery("SELECT count(*) FROM uid_table");
- while (rs.next()) {
- int count = rs.getInt(1);
- System.out.println("count = " + count);
- }
-
- } catch (SQLException e) {
- e.printStackTrace();
- fail();
- }finally{
- try {
- if (stat != null) {
- stat.close();
- }
- if(con!=null){
- con.close();
- }
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
-
-
-
-}
Copied: labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/HashPasswordDecoder.java (from rev 5508, labs/jbossesb/trunk/product/core/common/tests/src/org/jboss/soa/esb/connection/HashPasswordDecoder.java)
Deleted: labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderFuncTest.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderFuncTest.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderFuncTest.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -1,87 +0,0 @@
-/*
-* JBoss, Home of Professional Open Source
-* Copyright 2006, JBoss Inc., and individual contributors as indicated
-* by the @authors tag. See the copyright.txt in the distribution for a
-* full listing of individual contributors.
-*
-* This is free software; you can redistribute it and/or modify it
-* under the terms of the GNU Lesser General Public License as
-* published by the Free Software Foundation; either version 2.1 of
-* the License, or (at your option) any later version.
-*
-* This software is distributed in the hope that it will be useful,
-* but WITHOUT ANY WARRANTY; without even the implied warranty of
-* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-* Lesser General Public License for more details.
-*
-* You should have received a copy of the GNU Lesser General Public
-* License along with this software; if not, write to the Free
-* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
-* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
-*/
-package org.jboss.soa.esb.connection;
-
-import junit.framework.TestCase;
-
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-import java.util.Properties;
-
-/**
- * TODO
- *
- * @author MohitK
- * Date: Aug 1, 2006
- */
-public class PasswordDecoderFuncTest extends TestCase {
-
- Properties properties = new Properties();
-
- protected void setUp() throws Exception {
- properties.put(ConnectionProperties.DRIVER_CLASSNAME, "com.mysql.jdbc.Driver");
- properties.put(ConnectionProperties.CONNECTION_URL, "jdbc:mysql://localhost/rosetta");
- properties.put(ConnectionProperties.USERNAME, "rosetta");
- properties.setProperty(ConnectionProperties.PASSWORD_DECODER, PasswordDecoderTestImpl.class.getName());
- }
-
- public void testPasswordDecoder() {
-
- PoolDataSource ds = new PoolDataSource();
- ds.setConnectionProperties(properties);
- Connection con1 = null;
- Statement stat = null;
- try {
- con1 = ds.getConnection();
- stat = con1.createStatement();
- ResultSet rs = stat.executeQuery("SELECT count(*) FROM uid_table");
- while (rs.next()) {
- int count = rs.getInt(1);
- System.out.println("count = " + count);
- }
-
-
- } catch (SQLException e) {
- e.printStackTrace();
- fail();
- } finally {
- if (stat != null) {
- try {
- stat.close();
- } catch (SQLException e) {
- e.printStackTrace();
- fail();
- }
- }
- if (con1 != null) {
- try {
- con1.close();
- } catch (SQLException e) {
- e.printStackTrace();
- fail();
- }
- }
- }
- }
-}
Deleted: labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderTestImpl.java
===================================================================
--- labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderTestImpl.java 2006-08-06 15:15:13 UTC (rev 5511)
+++ labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/PasswordDecoderTestImpl.java 2006-08-06 15:32:52 UTC (rev 5512)
@@ -1,36 +0,0 @@
-/*
-* JBoss, Home of Professional Open Source
-* Copyright 2006, JBoss Inc., and individual contributors as indicated
-* by the @authors tag. See the copyright.txt in the distribution for a
-* full listing of individual contributors.
-*
-* This is free software; you can redistribute it and/or modify it
-* under the terms of the GNU Lesser General Public License as
-* published by the Free Software Foundation; either version 2.1 of
-* the License, or (at your option) any later version.
-*
-* This software is distributed in the hope that it will be useful,
-* but WITHOUT ANY WARRANTY; without even the implied warranty of
-* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-* Lesser General Public License for more details.
-*
-* You should have received a copy of the GNU Lesser General Public
-* License along with this software; if not, write to the Free
-* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
-* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
-*/
-package org.jboss.soa.esb.connection;
-
-import org.jboss.soa.esb.connection.PasswordDecoder;
-
-/**
- * TODO
- * @author MohitK
- * Date: Aug 1, 2006
- */
-public class PasswordDecoderTestImpl implements PasswordDecoder {
-
- public String decode(String encodedPassword) {
- return "rosetta";
- }
-}
Copied: labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/TestConnectionPool.java (from rev 5508, labs/jbossesb/trunk/product/core/common/tests/src/org/jboss/soa/esb/connection/TestConnectionPool.java)
Copied: labs/jbossesb/branches/refactor/product/core/common/tests/src/org/jboss/soa/esb/connection/TestPasswordDecoder.java (from rev 5508, labs/jbossesb/trunk/product/core/common/tests/src/org/jboss/soa/esb/connection/TestPasswordDecoder.java)
More information about the jboss-svn-commits
mailing list