Prevent concurrent access to pendingEvts when debug is on - Fixes
@@ -251,7 +251,6 @@ class CacheContinuousQueryPartitionRecovery {
if (skippedFiltered)
pendingEvts.headMap(lastFiredEvt).clear();
}
- }
if (log.isDebugEnabled()) {
log.debug("Will send to listener the following events [entries=" + entries +
@@ -261,6 +260,7 @@ class CacheContinuousQueryPartitionRecovery {
", partId=" + entry.partition() +
", pendingEvts=" + pendingEvts + ']');
}
+ }
return entries;
}
