Skip to content

Commit 426f11f

Browse files
committed
Fix Sonar Issue
Repeated literal.
1 parent 7e576d4 commit 426f11f

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

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

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,8 @@
4141
*/
4242
public class DestinationTopicPropertiesFactory {
4343

44+
private static final String DEPRECATION = "deprecation";
45+
4446
private static final String MAIN_TOPIC_SUFFIX = "";
4547

4648
private final DestinationTopicSuffixes destinationTopicSuffixes;
@@ -55,7 +57,7 @@ public class DestinationTopicPropertiesFactory {
5557

5658
private final KafkaOperations<?, ?> kafkaOperations;
5759

58-
@SuppressWarnings("deprecation")
60+
@SuppressWarnings(DEPRECATION)
5961
private final FixedDelayStrategy fixedDelayStrategy;
6062

6163
private final DltStrategy dltStrategy;
@@ -69,7 +71,7 @@ public class DestinationTopicPropertiesFactory {
6971
@Nullable
7072
private Boolean autoStartDltHandler;
7173

72-
@SuppressWarnings("deprecation")
74+
@SuppressWarnings(DEPRECATION)
7375
public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues,
7476
BinaryExceptionClassifier exceptionClassifier,
7577
int numPartitions, KafkaOperations<?, ?> kafkaOperations,
@@ -93,7 +95,7 @@ public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuff
9395
this.maxAttempts = this.backOffValues.size() + 1;
9496
}
9597

96-
@SuppressWarnings("deprecation")
98+
@SuppressWarnings(DEPRECATION)
9799
public DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues,
98100
BinaryExceptionClassifier exceptionClassifier,
99101
int numPartitions, KafkaOperations<?, ?> kafkaOperations,
@@ -135,7 +137,7 @@ private boolean isSingleTopicFixedDelay() {
135137
return isFixedDelay() && (isSingleTopicStrategy() || isSingleTopicSameIntervalTopicReuseStrategy());
136138
}
137139

138-
@SuppressWarnings("deprecation")
140+
@SuppressWarnings(DEPRECATION)
139141
private boolean isSingleTopicStrategy() {
140142
return FixedDelayStrategy.SINGLE_TOPIC.equals(this.fixedDelayStrategy);
141143
}
@@ -201,7 +203,7 @@ private BiPredicate<Integer, Throwable> getShouldRetryOn() {
201203
return (attempt, throwable) -> attempt < this.maxAttempts && this.exceptionClassifier.classify(throwable);
202204
}
203205

204-
@SuppressWarnings("deprecation")
206+
@SuppressWarnings(DEPRECATION)
205207
private DestinationTopic.Properties createRetryProperties(int index,
206208
BiPredicate<Integer, Throwable> shouldRetryOn) {
207209
int indexInBackoffValues = index - 1;

0 commit comments

Comments
 (0)