[jboss-cvs] JBossAS SVN: r112428 - branches/JBPAPP_5_1_0_Final_JBPAPP-7487/connector/src/main/org/jboss/resource/adapter/jdbc/remote.

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

Author: jbertram at redhat.com
Date: 2011-11-04 20:55:40 -0400 (Fri, 04 Nov 2011)
New Revision: 112428

Modified:
   branches/JBPAPP_5_1_0_Final_JBPAPP-7487/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java
Log:
JBPAPP-7487

Modified: branches/JBPAPP_5_1_0_Final_JBPAPP-7487/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java
===================================================================
--- branches/JBPAPP_5_1_0_Final_JBPAPP-7487/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java	2011-11-05 00:39:07 UTC (rev 112427)
+++ branches/JBPAPP_5_1_0_Final_JBPAPP-7487/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java	2011-11-05 00:55:40 UTC (rev 112428)
@@ -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