commit a06c5c886b160af8724339d8b010d20dbb5ea1a2
author Christian Schneider <cschneid@adobe.com> Tue Apr 16 15:33:34 2024 +0200
committer GitHub <noreply@github.com> Tue Apr 16 15:33:34 2024 +0200
tree bc2e3ec1cdec76879b1c995109c447303354cf86
parent a2c3f9cff15d6292642bd95e8237afc83ab6fa69

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

src/main/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java

diff --git a/src/main/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java b/src/main/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java
index 89eee8f..936cb84 100644
--- a/src/main/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java
+++ b/src/main/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java
@@ -91,8 +91,7 @@
 
     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());
     }
 }