SLING-7754: added some more logging
diff --git a/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueCleanupTask.java b/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueCleanupTask.java
index f41b16e..7a13e2e 100644
--- a/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueCleanupTask.java
+++ b/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueCleanupTask.java
@@ -102,7 +102,7 @@
continue;
}
- log.debug("removing empty folder {}", res.getPath());
+ log.debug("removing minute resource folder {}", res.getPath());
resolver.delete(res);
resolver.commit();
diff --git a/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueUtils.java b/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueUtils.java
index b221998..a54767e 100644
--- a/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueUtils.java
+++ b/src/main/java/org/apache/sling/distribution/queue/impl/resource/ResourceQueueUtils.java
@@ -228,11 +228,12 @@
*/
private static Resource getOrCreateMinuteResource(Resource root) throws PersistenceException {
- for (int i=0; i<2; i++) {
+ final int retries = 2;
+ for (int i=0; i < retries; i++) {
try {
return tryGetOrCreateMinutes(root);
} catch (PersistenceException e) {
- log.warn("creating minute resource failed. retrying {} more times.", 5-i);
+ log.warn("creating minute resource failed. retrying {} more times.", retries-i);
}
root.getResourceResolver().revert();
@@ -260,9 +261,10 @@
}
for (int i=0; i < 3; i++) {
- now.add(Calendar.MINUTE, i);
String newMinutePath = getTimePath(now);
Resource resource = createResource(root, newMinutePath);
+ log.debug("minute resource created {}", resource.getPath());
+ now.add(Calendar.MINUTE, 1);
}
resourceResolver.commit();
