You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by kw...@apache.org on 2019/01/11 08:22:41 UTC
[sling-org-apache-sling-event] branch master updated (d670edc ->
353631f)
This is an automated email from the ASF dual-hosted git repository.
kwin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-event.git.
from d670edc trivial: added license header to *.md files
add 7289dae SLING-7756 : Improve logging for Job retries
new 353631f SLING-7756 adjust log level and message
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.
Summary of changes:
.../org/apache/sling/event/impl/jobs/queues/JobQueueImpl.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
[sling-org-apache-sling-event] 01/01: SLING-7756 adjust log level
and message
Posted by kw...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kwin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-event.git
commit 353631f97592787116e9db47d102641ec5461df8
Author: Konrad Windszus <kw...@apache.org>
AuthorDate: Fri Jan 11 09:22:35 2019 +0100
SLING-7756 adjust log level and message
---
.../java/org/apache/sling/event/impl/jobs/queues/JobQueueImpl.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/main/java/org/apache/sling/event/impl/jobs/queues/JobQueueImpl.java b/src/main/java/org/apache/sling/event/impl/jobs/queues/JobQueueImpl.java
index 6476f23..5cabbbf 100644
--- a/src/main/java/org/apache/sling/event/impl/jobs/queues/JobQueueImpl.java
+++ b/src/main/java/org/apache/sling/event/impl/jobs/queues/JobQueueImpl.java
@@ -455,7 +455,7 @@ public class JobQueueImpl
retryCount++;
if ( retries != -1 && retryCount > retries ) {
if ( this.logger.isDebugEnabled() ) {
- this.logger.debug("Cancelled job {} after {} retries",
+ this.logger.error("Cancelled job {} after {} unsuccessful retries",
Utility.toString(handler.getJob()),
retries);
}
@@ -463,8 +463,9 @@ public class JobQueueImpl
} else {
info.reschedule = true;
handler.getJob().retry();
- this.logger.warn("Failed job {}, will retry, retryCount={}",
+ this.logger.warn("Failed job {}, will retry {} more time(s), retryCount={}",
Utility.toString(handler.getJob()),
+ retries-retryCount,
retryCount);
info.finalState = InternalJobState.FAILED;
}