Move SemaphoreBackPressureHandler#release(amount, reason) implementation to BatchAwareBackPressureHandler interface (#1251)

Author: loicrouchon

spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/BatchAwareBackPressureHandler.java

@@ -44,6 +44,16 @@ default void releaseBatch() {
 		release(getBatchSize(), ReleaseReason.NONE_FETCHED);
 	}
 
+	@Override
+	default void release(int amount, ReleaseReason reason) {
+		if (amount == getBatchSize() && reason == ReleaseReason.NONE_FETCHED) {
+			releaseBatch();
+		}
+		else {
+			release(amount);
+		}
+	}
+
 	/**
 	 * Return the configured batch size for this handler.
 	 * @return the batch size.

spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/SemaphoreBackPressureHandler.java

@@ -180,16 +180,6 @@ public void release(int amount) {
 				this.semaphore.availablePermits());
 	}
 
-	@Override
-	public void release(int amount, ReleaseReason reason) {
-		if (amount == this.batchSize && reason == ReleaseReason.NONE_FETCHED) {
-			releaseBatch();
-		}
-		else {
-			release(amount);
-		}
-	}
-
 	private int getPermitsToRelease(int amount) {
 		return this.hasAcquiredFullPermits.compareAndSet(true, false)
 				// The first process that gets here should release all permits except for inflight messages