Skip to content

Commit 8a6260e

Browse files
committed
Revert deprecation message, which is since 2.7
**Cherry-pick to `2.5.x`**
1 parent 0a0cd35 commit 8a6260e

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/ListenerUtils.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2017-2020 the original author or authors.
2+
* Copyright 2017-2021 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -153,10 +153,7 @@ public static String recordToString(ConsumerRecord<?, ?> record, boolean meta) {
153153
* @param lastIntervals a thread local containing the previous {@link BackOff}
154154
* interval for this thread.
155155
* @since 2.3.12
156-
* @deprecated since 2.7 in favor of
157-
* {@link #unrecoverableBackOff(BackOff, ThreadLocal, ThreadLocal, MessageListenerContainer)}.
158156
*/
159-
@Deprecated
160157
public static void unrecoverableBackOff(BackOff backOff, ThreadLocal<BackOffExecution> executions,
161158
ThreadLocal<Long> lastIntervals) {
162159

@@ -169,7 +166,7 @@ public static void unrecoverableBackOff(BackOff backOff, ThreadLocal<BackOffExec
169166
if (interval == BackOffExecution.STOP) {
170167
interval = lastIntervals.get();
171168
if (interval == null) {
172-
interval = Long.valueOf(0);
169+
interval = 0L;
173170
}
174171
}
175172
lastIntervals.set(interval);

0 commit comments

Comments
 (0)