You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2008/06/06 23:14:23 UTC
svn commit: r664129 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
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;
}