You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by tm...@apache.org on 2019/04/18 11:33:11 UTC
[sling-org-apache-sling-distribution-journal] branch master
updated: SLING-8361 - Log subscriber steps to manage consumption status
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 83dfcc4 SLING-8361 - Log subscriber steps to manage consumption status
83dfcc4 is described below
commit 83dfcc4c2041310f0168ab0c6a365d88a53d2c22
Author: tmaret <tm...@adobe.com>
AuthorDate: Thu Apr 18 13:31:03 2019 +0200
SLING-8361 - Log subscriber steps to manage consumption status
---
.../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 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 @@ public class DistributionSubscriber implements DistributionAgent {
s.put("offset", offset);
s.put("sent", false);
processedStatuses.store(resolver, s);
+ LOG.info("Stored status {}", s);
}
private void sendStoredStatus() {
@@ -687,6 +688,7 @@ public class DistributionSubscriber implements DistributionAgent {
.build();
sender.send(topics.getStatusTopic(), pkgStatMsg);
+ LOG.info("Sent status message {}", status);
}
private void sleep(int ms) {