[sling-org-apache-sling-distribution-journal] branch master updated: SLING-9151 - Log seeding messages being sent

[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 2de092d  SLING-9151 - Log seeding messages being sent
2de092d is described below

commit 2de092d5437b2eeafc77d953ce5ffa73d3ee2377
Author: tmaret <tma...@adobe.com>
AuthorDate: Wed Feb 26 15:58:14 2020 +0100

    SLING-9151 - Log seeding messages being sent
---
 .../journal/impl/queue/impl/PubQueueCache.java          | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git 
a/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCache.java
 
b/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCache.java
index 5a3ffa6..7eb3451 100644
--- 
a/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCache.java
+++ 
b/src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/PubQueueCache.java
@@ -135,7 +135,7 @@ public class PubQueueCache {
                 Reset.latest,
                 create(PackageMessage.class, this::handlePackage));
 
-        seeder = RunnableUtil.startBackgroundThread(this::sendSeedingMessages, 
"queue seeding");
+        seeder = RunnableUtil.startBackgroundThread(this::seedCache, "queue 
seeding");
     }
 
     @Nonnull
@@ -155,12 +155,20 @@ public class PubQueueCache {
         jmxRegs.stream().forEach(IOUtils::closeQuietly);
     }
 
-    private void sendSeedingMessages() {
+    private void seedCache() {
         LOG.info("Start message seeder");
-        MessageSender<PackageMessage> sender = 
messagingProvider.createSender();
+        try {
+            MessageSender<PackageMessage> sender = 
messagingProvider.createSender();
+            sendSeedingMessages(sender);
+        } finally {
+            LOG.info("Stop message seeder");
+        }
+    }
+
+    private void sendSeedingMessages(MessageSender<PackageMessage> sender) {
         while (! Thread.interrupted()) {
             PackageMessage pkgMsg = createTestMessage();
-            LOG.debug("Send seeding message");
+            LOG.info("Send seeding message");
             try {
                 sender.send(topic, pkgMsg);
                 sleep(seedingDelayMs);
@@ -169,7 +177,6 @@ public class PubQueueCache {
                 sleep(seedingDelayMs * 10);
             }
         }
-        LOG.info("Stop message seeder");
     }
 
     private void sleep(long sleepMs) {