(sling-org-apache-sling-distribution-journal) branch master updated: SLING-12289 - Only store status if it does not yet exist (#140)

[cschneider]

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

cschneider pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git


The following commit(s) were added to refs/heads/master by this push:
     new a06c5c8  SLING-12289 - Only store status if it does not yet exist 
(#140)
a06c5c8 is described below

commit a06c5c886b160af8724339d8b010d20dbb5ea1a2
Author: Christian Schneider <cschn...@adobe.com>
AuthorDate: Tue Apr 16 15:33:34 2024 +0200

    SLING-12289 - Only store status if it does not yet exist (#140)
---
 .../distribution/journal/impl/precondition/PackageStatusWatcher.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 @@ public class PackageStatusWatcher implements Closeable {
 
     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());
     }
 }