Fix Sonar Issues

Author: garyrussell

Diff for: spring-kafka/src/main/java/org/springframework/kafka/listener/PartitionPausingBackOffManagerFactory.java

@@ -51,7 +51,7 @@ public class PartitionPausingBackOffManagerFactory extends AbstractKafkaBackOffM
 	 */
 	public PartitionPausingBackOffManagerFactory(KafkaConsumerTimingAdjuster timingAdjustmentManager) {
 		this.clock = getDefaultClock();
-		setTimingAdjustmentManager(timingAdjustmentManager);
+		doSetTimingAdjustmentManager(timingAdjustmentManager);
 	}
 
 	/**
@@ -62,7 +62,7 @@ public PartitionPausingBackOffManagerFactory(KafkaConsumerTimingAdjuster timingA
 	 */
 	public PartitionPausingBackOffManagerFactory(TaskExecutor timingAdjustmentManagerTaskExecutor) {
 		this.clock = getDefaultClock();
-		setTaskExecutor(timingAdjustmentManagerTaskExecutor);
+		doSetTaskExecutor(timingAdjustmentManagerTaskExecutor);
 	}
 
 	/**
@@ -73,7 +73,7 @@ public PartitionPausingBackOffManagerFactory(TaskExecutor timingAdjustmentManage
 	 */
 	public PartitionPausingBackOffManagerFactory(boolean timingAdjustmentEnabled) {
 		this.clock = getDefaultClock();
-		setTimingAdjustmentEnabled(timingAdjustmentEnabled);
+		this.timingAdjustmentEnabled = timingAdjustmentEnabled;
 	}
 
 	/**
@@ -118,7 +118,11 @@ public void setTimingAdjustmentEnabled(boolean timingAdjustmentEnabled) {
 	 *
 	 * @param timingAdjustmentManager the adjustmentManager to be used.
 	 */
-	public final void setTimingAdjustmentManager(KafkaConsumerTimingAdjuster timingAdjustmentManager) {
+	public void setTimingAdjustmentManager(KafkaConsumerTimingAdjuster timingAdjustmentManager) {
+		doSetTimingAdjustmentManager(timingAdjustmentManager);
+	}
+
+	private void doSetTimingAdjustmentManager(KafkaConsumerTimingAdjuster timingAdjustmentManager) {
 		Assert.isTrue(this.timingAdjustmentEnabled, () -> "TimingAdjustment is disabled for this factory.");
 		this.timingAdjustmentManager = timingAdjustmentManager;
 	}
@@ -127,7 +131,11 @@ public final void setTimingAdjustmentManager(KafkaConsumerTimingAdjuster timingA
 	 * Set the {@link TaskExecutor} that will be used in the {@link KafkaConsumerTimingAdjuster}.
 	 * @param taskExecutor the taskExecutor to be used.
 	 */
-	public final void setTaskExecutor(TaskExecutor taskExecutor) {
+	public void setTaskExecutor(TaskExecutor taskExecutor) {
+		doSetTaskExecutor(taskExecutor);
+	}
+
+	private void doSetTaskExecutor(TaskExecutor taskExecutor) {
 		Assert.isTrue(this.timingAdjustmentEnabled, () -> "TimingAdjustment is disabled for this factory.");
 		this.taskExecutor = taskExecutor;
 	}