commit 0043e5d578d7a76504ba79c152e4436b531b3508
author Dan Klco <dan.klco@perficient.com> Mon Feb 01 16:58:46 2021 -0500
committer Dan Klco <dan.klco@perficient.com> Mon Feb 01 16:58:46 2021 -0500
tree 0f9749213401d7d2534b0e580480d9168ae4530c
parent 82bb34d76a7dfa6d65e5d3546eb3c83b00cf1be1

Updating to use a boolean flag to indicate interruption rather than throwing an exception

src/main/java/org/apache/sling/jcr/maintenance/internal/VersionCleanup.java

diff --git a/src/main/java/org/apache/sling/jcr/maintenance/internal/VersionCleanup.java b/src/main/java/org/apache/sling/jcr/maintenance/internal/VersionCleanup.java
index 31a7372..ac04821 100644
--- a/src/main/java/org/apache/sling/jcr/maintenance/internal/VersionCleanup.java
+++ b/src/main/java/org/apache/sling/jcr/maintenance/internal/VersionCleanup.java
@@ -123,10 +123,9 @@
 
     }
 
-    private void findVersions(final Session session, final Resource resource)
-            throws RepositoryException, InterruptedException {
+    private boolean findVersions(final Session session, final Resource resource) throws RepositoryException {
         if (Thread.interrupted()) {
-            throw new InterruptedException("Process interrupted");
+            return true;
         }
         log.debug("Finding versions under: {}", resource.getPath());
         if ("nt:versionHistory".equals(resource.getResourceType())) {
@@ -134,9 +133,12 @@
             cleanupVersions(session, resource);
         } else {
             for (final Resource child : resource.getChildren()) {
-                findVersions(session, child);
+                if (findVersions(session, child)) {
+                    return true;
+                }
             }
         }
+        return false;
     }
 
     private boolean isMatchingVersion(Session session, String path, VersionHistory versionHistory)
@@ -171,9 +173,6 @@
 
     private void doRun() {
         log.info("Running version cleanup");
-        boolean interrupted = false;
-        boolean succeeded = false;
-        String failureMessage = null;
         lastCleanedVersions = 0;
         try {
             try (final ResourceResolver adminResolver = factory.getServiceResourceResolver(
@@ -183,26 +182,18 @@
                         .orElseThrow(() -> new RepositoryException("Failed to get session"));
                 for (final Resource folder : versionRoot.getChildren()) {
                     log.info("Traversing and cleaning: {}", folder.getPath());
-                    findVersions(session, folder);
+                    if (findVersions(session, folder)) {
+                        break;
+                    }
                 }
-                succeeded = true;
+                lastFailureMessage = null;
             }
         } catch (final LoginException le) {
             log.error("Failed to run version cleanup, cannot get service user", le);
-            failureMessage = "Failed to run version cleanup, cannot get service user";
+            lastFailureMessage = "Failed to run version cleanup, cannot get service user";
         } catch (final RepositoryException re) {
             log.error("Failed to run version cleanup", re);
-            failureMessage = "Failed to run version cleanup";
-        } catch (final InterruptedException e) { // no need to do anything, at this point nearly done
-            log.info("Process interrupted, quitting");
-            interrupted = true;
-        } finally {
-            if (succeeded) {
-                this.lastFailureMessage = null;
-            } else if (!interrupted) {
-                lastFailureMessage = failureMessage != null ? failureMessage
-                        : "Failed due to unexpected exception, see logs";
-            }
+            lastFailureMessage = "Failed to run version cleanup";
         }
     }