Author: timfox Date: 2009-11-03 10:02:43 -0500 (Tue, 03 Nov 2009) New Revision: 8194 Modified: trunk/src/main/org/hornetq/core/server/group/impl/RemoteGroupingHandler.java Log: oops forgot in last commit Modified: trunk/src/main/org/hornetq/core/server/group/impl/RemoteGroupingHandler.java =================================================================== --- trunk/src/main/org/hornetq/core/server/group/impl/RemoteGroupingHandler.java 2009-11-03 15:00:57 UTC (rev 8193) +++ trunk/src/main/org/hornetq/core/server/group/impl/RemoteGroupingHandler.java 2009-11-03 15:02:43 UTC (rev 8194) @@ -13,10 +13,10 @@ package org.hornetq.core.server.group.impl; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; @@ -48,7 +48,7 @@ private final SimpleString address; - private final Map<SimpleString, Response> responses = new HashMap<SimpleString, Response>(); + private final Map<SimpleString, Response> responses = new ConcurrentHashMap<SimpleString, Response>(); private final Lock lock = new ReentrantLock(); @@ -56,7 +56,7 @@ private final int timeout; - private final ConcurrentHashMap<SimpleString, List<SimpleString>> groupMap = new ConcurrentHashMap<SimpleString, List<SimpleString>>(); + private final ConcurrentMap<SimpleString, List<SimpleString>> groupMap = new ConcurrentHashMap<SimpleString, List<SimpleString>>(); public RemoteGroupingHandler(final ManagementService managementService, final SimpleString name,