[jboss-cvs] JBossAS SVN: r112587 - branches/JBPAPP_4_3_0_GA_CP08_JBPAPP-8010/connector/src/main/org/jboss/resource/adapter/jdbc/remote.

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

Author: jameslivingston
Date: 2012-01-30 21:08:42 -0500 (Mon, 30 Jan 2012)
New Revision: 112587

Modified:
   branches/JBPAPP_4_3_0_GA_CP08_JBPAPP-8010/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java
Log:
Fix JBPAPP-8010 by backporting thread-safety fix.

Modified: branches/JBPAPP_4_3_0_GA_CP08_JBPAPP-8010/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java
===================================================================
--- branches/JBPAPP_4_3_0_GA_CP08_JBPAPP-8010/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java	2012-01-30 05:50:22 UTC (rev 112586)
+++ branches/JBPAPP_4_3_0_GA_CP08_JBPAPP-8010/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java	2012-01-31 02:08:42 UTC (rev 112587)
@@ -39,6 +39,7 @@
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.Iterator;
 import java.util.Map;
@@ -85,12 +86,12 @@
    private ObjectName jmxInvokerName;
    private Invoker delegateInvoker;
    private Object theProxy;
-   private HashMap marshalledInvocationMapping = new HashMap();
-   private HashMap connectionMap = new HashMap();
-   private HashMap statementMap = new HashMap();
-   private HashMap resultSetMap = new HashMap();
-   private HashMap lobMap = new HashMap();
-   private HashMap databaseMetaDataMap = new HashMap();
+   private Map marshalledInvocationMapping = new HashMap();
+   private Map connectionMap = Collections.synchronizedMap(new HashMap());
+   private Map statementMap = Collections.synchronizedMap(new HashMap());
+   private Map resultSetMap = Collections.synchronizedMap(new HashMap());
+   private Map lobMap = Collections.synchronizedMap(new HashMap());
+   private Map databaseMetaDataMap = Collections.synchronizedMap(new HashMap());
    private boolean trace = log.isTraceEnabled();
 
    protected void startService() throws Exception