Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Sonar Issues

Browse Source
This commit is contained in:
Gary Russell
2022-06-16 12:56:11 -04:00
parent 12c35403f2
commit 70a7274c5d
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
spring-kafka/src/main/java/org/springframework/kafka/listener/PartitionPausingBackOffManagerFactory.java
View File

@@ -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 class PartitionPausingBackOffManagerFactory extends AbstractKafkaBackOffM
*/
public PartitionPausingBackOffManagerFactory(TaskExecutor timingAdjustmentManagerTaskExecutor) {
this.clock = getDefaultClock();
setTaskExecutor(timingAdjustmentManagerTaskExecutor);
doSetTaskExecutor(timingAdjustmentManagerTaskExecutor);
}
/**
@@ -73,7 +73,7 @@ public class PartitionPausingBackOffManagerFactory extends AbstractKafkaBackOffM
*/
public PartitionPausingBackOffManagerFactory(boolean timingAdjustmentEnabled) {
this.clock = getDefaultClock();
setTimingAdjustmentEnabled(timingAdjustmentEnabled);
this.timingAdjustmentEnabled = timingAdjustmentEnabled;
}
/**
@@ -118,7 +118,11 @@ public class PartitionPausingBackOffManagerFactory extends AbstractKafkaBackOffM
*
* @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 class PartitionPausingBackOffManagerFactory extends AbstractKafkaBackOffM
* 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;
}