(sling-org-apache-sling-distribution-journal) branch master updated: SLING-12379 - Send discovery message when package is processed (#156)

[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 6c0e65b  SLING-12379 - Send discovery message when package is 
processed (#156)
6c0e65b is described below

commit 6c0e65b67dd730005e80fb4d1bda0123edbbe54c
Author: Christian Schneider <cschn...@adobe.com>
AuthorDate: Tue Nov 26 12:36:28 2024 +0100

    SLING-12379 - Send discovery message when package is processed (#156)
---
 .../distribution/journal/impl/subscriber/DistributionSubscriber.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java
 
b/src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java
index 4515ef9..ae51c5b 100644
--- 
a/src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java
+++ 
b/src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java
@@ -333,6 +333,8 @@ public class DistributionSubscriber {
                 // Catch all to prevent processing from stopping
                 LOG.error("Error processing queue item", e);
                 delay.await(catchAllDelay.getAsLong());
+            } finally {
+                announcer.run();
             }
         }
         LOG.info("Stopped Queue processor");