You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cs...@apache.org on 2024/06/24 06:09:00 UTC
(sling-org-apache-sling-distribution-journal) branch SLING-12345 created (now 48356d1)
This is an automated email from the ASF dual-hosted git repository.
cschneider pushed a change to branch SLING-12345
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git
at 48356d1 SLING-12345 - Log import duration after import
This branch includes the following new commits:
new 48356d1 SLING-12345 - Log import duration after import
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(sling-org-apache-sling-distribution-journal) 01/01: SLING-12345 - Log import duration after import
Posted by cs...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
cschneider pushed a commit to branch SLING-12345
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git
commit 48356d1aa323ebe357e1d83f188c6bc0e6ec1e8c
Author: Christian Schneider <cs...@adobe.com>
AuthorDate: Mon Jun 24 08:08:45 2024 +0200
SLING-12345 - Log import duration after import
---
.../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);