This is an automated email from the ASF dual-hosted git repository. cschneider pushed a commit to branch SLING-12379 in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git
commit e17656a265c982b8b8da3c9df76edcd4f7e89c35 Author: Christian Schneider <[email protected]> AuthorDate: Tue Nov 26 12:35:33 2024 +0100 SLING-12379 - Send discovery message when package is processed --- .../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");
