commit 0e5cd094efbb67d1d528c3f227b11d8687b2ac5d
author Christian Schneider <cschneid@adobe.com> Wed Jul 10 16:36:45 2019 +0200
committer Christian Schneider <cschneid@adobe.com> Wed Jul 10 16:36:45 2019 +0200
tree 3bcd7e83c890c4d3208553e0207248bab4e13c8e
parent 67a9b11942481f6b7414f0449305d68f7fd0a867

SLING-8443 Fix error

src/main/java/org/apache/sling/distribution/journal/impl/shared/JournalAvailableChecker.java

diff --git a/src/main/java/org/apache/sling/distribution/journal/impl/shared/JournalAvailableChecker.java b/src/main/java/org/apache/sling/distribution/journal/impl/shared/JournalAvailableChecker.java
index e7ff4b7..0514706 100644
--- a/src/main/java/org/apache/sling/distribution/journal/impl/shared/JournalAvailableChecker.java
+++ b/src/main/java/org/apache/sling/distribution/journal/impl/shared/JournalAvailableChecker.java
@@ -103,8 +103,6 @@
 
     private void available() {
         LOG.info("Journal is available");
-        IOUtils.closeQuietly(this.backoffRetry);
-        this.backoffRetry = null;
         if (this.reg == null) {
             this.reg = context.registerService(JournalAvailable.class, this, null);
         }
@@ -146,7 +144,7 @@
     public synchronized void handleEvent(Event event) {
         String type = (String) event.getProperty(ExceptionEventSender.KEY_TYPE);
         int curNumErrors = this.numErrors.incrementAndGet();
-        if (this.backoffRetry == null && curNumErrors >= MIN_ERRORS) {
+        if (curNumErrors >= MIN_ERRORS) {
             LOG.warn("Received exception event {}. Journal is considered unavailable.", type);
             unRegister();
             this.numErrors.set(0);