fixed ConcurrentModificationException in River class

Erudika · Dec 27, 2020 · 62f1d88 · 62f1d88
1 parent d2c6d9a
commit 62f1d88
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/para-server/src/main/java/com/erudika/para/queue/River.java b/para-server/src/main/java/com/erudika/para/queue/River.java
@@ -279,7 +279,7 @@ protected int processIndexPayload(String appid, String opId, Map<String, Object>
 			}
 			return 1;
 		} catch (Exception e) {
-			logger.error("Indexing operation " + opId + " failed!", e);
+			logger.error("Indexing operation " + opId + " failed for app '" + appid + "'!", e);
 		}
 		return 0;
 	}
@@ -306,7 +306,7 @@ private void indexAllWithRetry(String appid, Object payload) {
 		Map<String, ParaObject> objs = Para.getDAO().readAll(appid, ids, true);
 		Para.getSearch().indexAll(appid, objs.values().stream().filter(v -> v != null).collect(Collectors.toList()));
 
-		if (objs.keySet().stream().anyMatch(k -> objs.get(k) == null)) {
+		if (objs.containsValue(null)) {
 			if (pendingIds == null) {
 				pendingIds = new ConcurrentHashMap<>();
 			}