This is an automated email from the ASF dual-hosted git repository. tmaret pushed a commit to branch SLING-9464 in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git
commit d8aa06a5e4d88fc447a73365e06451466ae41977 Author: tmaret <[email protected]> AuthorDate: Sun May 24 17:17:42 2020 +0200 SLING-9464 - Reference the PublisherConfigurationAvailable service to avoid enabling the cache on instances that don't require it --- .../distribution/journal/impl/queue/impl/PubQueueCacheService.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCacheService.java b/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCacheService.java index 6609b8b..5f794e4 100644 --- a/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCacheService.java +++ b/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCacheService.java @@ -22,6 +22,7 @@ import javax.annotation.Nonnull; import javax.annotation.ParametersAreNonnullByDefault; import org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService; +import org.apache.sling.distribution.journal.impl.shared.PublisherConfigurationAvailable; import org.apache.sling.distribution.journal.impl.shared.Topics; import org.apache.sling.distribution.journal.impl.queue.OffsetQueue; import org.apache.sling.distribution.journal.MessagingProvider; @@ -62,6 +63,12 @@ public class PubQueueCacheService implements Runnable { @Reference private JournalAvailable journalAvailable; + /** + * The cache is active only when at least one DistributionSubscriber agent is configured. + */ + @Reference + private PublisherConfigurationAvailable publisherConfigurationAvailable; + @Reference private MessagingProvider messagingProvider;
