SLING-12289 - Only store status if it does not yet exist (#140)

apache · Apr 16, 2024 · a06c5c8 · a06c5c8
1 parent a2c3f9c
commit a06c5c8
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...in/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java b/...in/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java
@@ -91,8 +91,7 @@ public void close() throws IOException {
 
     private void handle(MessageInfo info, PackageStatusMessage pkgStatusMsg) {
         long pkgOffset = pkgStatusMsg.getOffset();
-        // TODO: check revision
         Map<Long, Status> agentStatus = getAgentStatus(pkgStatusMsg.getSubAgentName());
-        agentStatus.put(pkgOffset, pkgStatusMsg.getStatus());
+        agentStatus.computeIfAbsent(pkgOffset, offset -> pkgStatusMsg.getStatus());
     }
 }