From b62f47465b2c749d0c0278621d563db07c43015f Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Fri, 6 Jun 2008 21:14:23 +0000 Subject: QPID-1124 : Use thread-safe map for messageListeners git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@664129 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'java/client/src') diff --git a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java index 0c0341490a..f7d54a681f 100644 --- a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java +++ b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java @@ -5,6 +5,7 @@ import java.io.IOException; 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 @@ public class ClientSession extends org.apache.qpidity.transport.Session implemen private static long MAX_NOT_SYNC_DATA_LENGH; private static long MAX_NOT_FLUSH_DATA_LENGH; - private Map _messageListeners = new HashMap(); + private Map _messageListeners = new ConcurrentHashMap(); private ClosedListener _exceptionListner; private RangeSet _rejectedMessages; private long _currentDataSizeNotSynced; @@ -196,7 +197,7 @@ public class ClientSession extends org.apache.qpidity.transport.Session implemen _exceptionListner.onClosed(null, null, null); } - Map getMessageListerners() + Map getMessageListeners() { return _messageListeners; } -- cgit v1.2.1