(sling-org-apache-sling-distribution-journal) branch master updated: SLING-12345 - Log import duration after import (#151)

[cschneider]

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

cschneider 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 d0b8d85  SLING-12345 - Log import duration after import (#151)
d0b8d85 is described below

commit d0b8d8567dc3017a686539bd854905e2c8cfbbe8
Author: Christian Schneider <cschn...@adobe.com>
AuthorDate: Mon Jun 24 09:52:49 2024 +0200

    SLING-12345 - Log import duration after import (#151)
---
 .../org/apache/sling/distribution/journal/bookkeeper/BookKeeper.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeper.java
 
b/src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeper.java
index 1ee7f06..489f6dd 100644
--- 
a/src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeper.java
+++ 
b/src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeper.java
@@ -176,7 +176,8 @@ public class BookKeeper {
 
             Event event = new AppliedEvent(pkgMsg, 
config.getSubAgentName()).toEvent();
             eventAdmin.postEvent(event);
-            log.info("Imported distribution package {} at offset={}", pkgMsg, 
offset);
+            long currentImporturationMs = System.currentTimeMillis() - 
importStartTime;
+            log.info("Imported distribution package {} at offset={} took 
importDurationMs={}", pkgMsg, offset, currentImporturationMs);
             
subscriberMetrics.getPackageStatusCounter(pkgMsg.getPubAgentName(), 
Status.IMPORTED).increment();
         } catch (DistributionException | LoginException | IOException | 
RuntimeException | ImportPreProcessException |ImportPostProcessException e) {
             failure(pkgMsg, offset, e);