[hornetq-commits] JBoss hornetq SVN: r8194 - trunk/src/main/org/hornetq/core/server/group/impl.

[do-not-reply at jboss.org]

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,