[sling-org-apache-sling-distribution-journal] branch master updated: SLING-9464 - Reference the PublisherConfigurationAvailable service to avoid enabling the cache on instances that don't require it (#33)

[tmaret]

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

tmaret 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 07416be  SLING-9464 - Reference the PublisherConfigurationAvailable 
service to avoid enabling the cache on instances that don't require it (#33)
07416be is described below

commit 07416be36448c2e6dc5ce5259dbe8d745dd8db14
Author: Timothee Maret <tma...@apache.org>
AuthorDate: Mon May 25 14:00:19 2020 +0200

    SLING-9464 - Reference the PublisherConfigurationAvailable service to avoid 
enabling the cache on instances that don't require it (#33)
    
    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;