Skip to content

Commit 9d51ef9

Browse files
authored
Fix property name typo in BackOffValuesGenerator
1 parent a067eaa commit 9d51ef9

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/BackOffValuesGenerator.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -44,27 +44,27 @@ public class BackOffValuesGenerator {
4444

4545
private static final BackOffPolicy DEFAULT_BACKOFF_POLICY = new FixedBackOffPolicy();
4646

47-
private final int numberOfvaluesToCreate;
47+
private final int numberOfValuesToCreate;
4848

4949
private final BackOffPolicy backOffPolicy;
5050

5151
public BackOffValuesGenerator(int providedMaxAttempts, BackOffPolicy providedBackOffPolicy) {
52-
this.numberOfvaluesToCreate = getMaxAttemps(providedMaxAttempts) - 1;
52+
this.numberOfValuesToCreate = getMaxAttempts(providedMaxAttempts) - 1;
5353
BackOffPolicy policy = providedBackOffPolicy != null ? providedBackOffPolicy : DEFAULT_BACKOFF_POLICY;
5454
checkBackOffPolicyTipe(policy);
5555
this.backOffPolicy = policy;
5656
}
5757

58-
public int getMaxAttemps(int providedMaxAttempts) {
58+
public int getMaxAttempts(int providedMaxAttempts) {
5959
return providedMaxAttempts != RetryTopicConstants.NOT_SET
6060
? providedMaxAttempts
6161
: RetryTopicConstants.DEFAULT_MAX_ATTEMPTS;
6262
}
6363

6464
public List<Long> generateValues() {
6565
return NoBackOffPolicy.class.isAssignableFrom(this.backOffPolicy.getClass())
66-
? generateFromNoBackOffPolicy(this.numberOfvaluesToCreate)
67-
: generateFromSleepingBackOffPolicy(this.numberOfvaluesToCreate, this.backOffPolicy);
66+
? generateFromNoBackOffPolicy(this.numberOfValuesToCreate)
67+
: generateFromSleepingBackOffPolicy(this.numberOfValuesToCreate, this.backOffPolicy);
6868
}
6969

7070
private void checkBackOffPolicyTipe(BackOffPolicy providedBackOffPolicy) {

0 commit comments

Comments
 (0)