This is an automated email from the ASF dual-hosted git repository.

tv pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/commons-jcs.git

commit e7d533660728e1789fff9cf22107b1d81b7d74c9
Author: Thomas Vandahl <[email protected]>
AuthorDate: Mon Apr 13 14:51:42 2020 +0200

    Fix log message
---
 .../jcs/auxiliary/remote/server/RemoteCacheServer.java  | 17 +++++++----------
 1 file changed, 7 insertions(+), 10 deletions(-)

diff --git 
a/commons-jcs-core/src/main/java/org/apache/commons/jcs/auxiliary/remote/server/RemoteCacheServer.java
 
b/commons-jcs-core/src/main/java/org/apache/commons/jcs/auxiliary/remote/server/RemoteCacheServer.java
index 05d271b..1d91bb6 100644
--- 
a/commons-jcs-core/src/main/java/org/apache/commons/jcs/auxiliary/remote/server/RemoteCacheServer.java
+++ 
b/commons-jcs-core/src/main/java/org/apache/commons/jcs/auxiliary/remote/server/RemoteCacheServer.java
@@ -1126,14 +1126,11 @@ public class RemoteCacheServer<K, V>
      */
     private static <KK, VV> void cleanupEventQMap( Map<Long, 
ICacheEventQueue<KK, VV>> eventQMap )
     {
-        synchronized ( eventQMap )
-        {
-            // this does not care if the q is alive (i.e. if
-            // there are active threads; it cares if the queue
-            // is working -- if it has not encountered errors
-            // above the failure threshold
-            eventQMap.entrySet().removeIf(e -> !e.getValue().isWorking());
-        }
+        // this does not care if the q is alive (i.e. if
+        // there are active threads; it cares if the queue
+        // is working -- if it has not encountered errors
+        // above the failure threshold
+        eventQMap.entrySet().removeIf(e -> !e.getValue().isWorking());
     }
 
     /**
@@ -1317,8 +1314,8 @@ public class RemoteCacheServer<K, V>
         idTypeMap.remove( Long.valueOf( listenerId ) );
         idIPMap.remove( Long.valueOf( listenerId ) );
 
-        log.info( "After removing listener [{0}] cache region {1}'s listener 
size [{2}]",
-                listenerId, cacheName, cacheDesc.eventQMap.size() );
+        log.info( "After removing listener [{0}] cache region {1} listener 
size [{2}]",
+                listenerId, cacheName, eventQMap.size() );
     }
 
     /**

Reply via email to