commit 83dfcc4c2041310f0168ab0c6a365d88a53d2c22
author tmaret <tmaret@adobe.com> Thu Apr 18 13:31:03 2019 +0200
committer tmaret <tmaret@adobe.com> Thu Apr 18 13:31:03 2019 +0200
tree 53b7c761de8448f2548d0e581d3ff70c40ba4ac4
parent aca35fbff945500e9d569a72cddfd43ef0e1234f

SLING-8361 - Log subscriber steps to manage consumption status

src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java

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 44d603b..4eb0050 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
@@ -641,6 +641,7 @@
         s.put("offset", offset);
         s.put("sent", false);
         processedStatuses.store(resolver, s);
+        LOG.info("Stored status {}", s);
     }
 
     private void sendStoredStatus() {
@@ -687,6 +688,7 @@
                 .build();
 
         sender.send(topics.getStatusTopic(), pkgStatMsg);
+        LOG.info("Sent status message {}", status);
     }
 
     private void sleep(int ms) {