cleanup

vikinghawk · acogoluegnes · commit e39cb6fcc190 · 2021-02-15T15:09:17.000+01:00
(cherry picked from commit ebb5859)
diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
@@ -560,7 +560,6 @@ public void removeConsumerRecoveryListener(ConsumerRecoveryListener listener) {
     }
 
     private synchronized void beginAutomaticRecovery() throws InterruptedException {
-        this.wait(this.params.getRecoveryDelayHandler().getDelay(0));
         final long delay = this.params.getRecoveryDelayHandler().getDelay(0);
         if (delay > 0)  {
             this.wait(delay);

Original file line number	Diff line number	Diff line change
`@@ -560,7 +560,6 @@ public void removeConsumerRecoveryListener(ConsumerRecoveryListener listener) {`
`560`	`560`	`}`
`561`	`561`
`562`	`562`	`private synchronized void beginAutomaticRecovery() throws InterruptedException {`
`563`		`- this.wait(this.params.getRecoveryDelayHandler().getDelay(0));`
`564`	`563`	`final long delay = this.params.getRecoveryDelayHandler().getDelay(0);`
`565`	`564`	`if (delay > 0) {`
`566`	`565`	`this.wait(delay);`