[sling-org-apache-sling-distribution-journal] branch master updated: SLING-10066 reduce loglevel to DEBUG (#62)

[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 deef29a  SLING-10066 reduce loglevel to DEBUG (#62)
deef29a is described below

commit deef29a280bfc1c9052a1df4e8bfb4917f48a22c
Author: Jörg Hoh <joerg...@users.noreply.github.com>
AuthorDate: Mon Jan 18 19:24:12 2021 +0100

    SLING-10066 reduce loglevel to DEBUG (#62)
    
    Thanks @joerghoh , merged.
---
 .../distribution/journal/impl/publisher/PackageDistributedNotifier.java | 2 +-
 .../org/apache/sling/distribution/journal/queue/impl/PubQueueCache.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageDistributedNotifier.java
 
b/src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageDistributedNotifier.java
index 07eee83..b6cc54d 100644
--- 
a/src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageDistributedNotifier.java
+++ 
b/src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageDistributedNotifier.java
@@ -100,7 +100,7 @@ public class PackageDistributedNotifier implements 
TopologyChangeHandler {
     }
 
     protected void notifyDistributed(String pubAgentName, 
DistributionQueueItem queueItem) {
-        LOG.info("Sending distributed notifications for pub agent {} queue 
item {}", pubAgentName, queueItem.getPackageId());
+        LOG.debug("Sending distributed notifications for pub agent {} queue 
item {}", pubAgentName, queueItem.getPackageId());
         sendEvt(pubAgentName, queueItem);
         if (sendMsg) {
             sendMsg(pubAgentName, queueItem);
diff --git 
a/src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueCache.java
 
b/src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueCache.java
index 8aced92..66474b5 100644
--- 
a/src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueCache.java
+++ 
b/src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueCache.java
@@ -223,7 +223,7 @@ public class PubQueueCache {
 
     private void sendQueuedEvent(FullMessage<PackageMessage> fMessage) {
         long offset = fMessage.getInfo().getOffset();
-        LOG.info("Queueing message package-id={}, offset={}", 
fMessage.getMessage().getPkgId(), offset);
+        LOG.debug("Queueing message package-id={}, offset={}", 
fMessage.getMessage().getPkgId(), offset);
         PackageMessage message = fMessage.getMessage();
         final Event queuedEvent = 
DistributionEvent.eventPackageQueued(message, message.getPubAgentName());
         eventAdmin.postEvent(queuedEvent);