svn commit: r664129 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java

[rgodfrey]

Author: rgodfrey
Date: Fri Jun  6 14:14:23 2008
New Revision: 664129

URL: http://svn.apache.org/viewvc?rev=664129&view=rev
Log:
QPID-1124 : Use thread-safe map for messageListeners

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java?rev=664129&r1=664128&r2=664129&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
 Fri Jun  6 14:14:23 2008
@@ -5,6 +5,7 @@
 import java.nio.ByteBuffer;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 import org.apache.qpidity.QpidException;
 import org.apache.qpidity.api.Message;
@@ -48,7 +49,7 @@
     private static  long MAX_NOT_SYNC_DATA_LENGH;
     private static  long MAX_NOT_FLUSH_DATA_LENGH;
 
-    private Map<String,MessagePartListener> _messageListeners = new 
HashMap<String,MessagePartListener>();
+    private Map<String,MessagePartListener> _messageListeners = new 
ConcurrentHashMap<String,MessagePartListener>();
     private ClosedListener _exceptionListner;
     private RangeSet _rejectedMessages;
     private long _currentDataSizeNotSynced;
@@ -196,7 +197,7 @@
         _exceptionListner.onClosed(null, null, null);
     }
 
-    Map<String,MessagePartListener> getMessageListerners()
+    Map<String,MessagePartListener> getMessageListeners()
     {
         return _messageListeners;
     }