[jboss-cvs] JBossAS SVN: r112190 - branches/JBPAPP_5_1/connector/src/main/org/jboss/resource/adapter/jdbc/remote.

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

Author: jameslivingston
Date: 2011-08-31 18:41:37 -0400 (Wed, 31 Aug 2011)
New Revision: 112190

Modified:
   branches/JBPAPP_5_1/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java
Log:
JBPAPP-7102: Fix server-side multi-threaded access to remote data sources


Modified: branches/JBPAPP_5_1/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java
===================================================================
--- branches/JBPAPP_5_1/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java	2011-08-31 22:40:07 UTC (rev 112189)
+++ branches/JBPAPP_5_1/connector/src/main/org/jboss/resource/adapter/jdbc/remote/WrapperDataSourceService.java	2011-08-31 22:41:37 UTC (rev 112190)
@@ -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