Skip to content

Commit ea7cc33

Browse files
committed
GH-1886 More RetryTemplate Related Deprecations
1 parent 59f2550 commit ea7cc33

File tree

2 files changed

+14
-0
lines changed

2 files changed

+14
-0
lines changed

Diff for: spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java

+2
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,9 @@ public void setRecoveryCallback(RecoveryCallback<? extends Object> recoveryCallb
206206
* alive.
207207
* @param statefulRetry true to enable stateful retry.
208208
* @since 2.1.3
209+
* @deprecated since 2.8 - use a suitably configured error handler instead.
209210
*/
211+
@Deprecated
210212
public void setStatefulRetry(boolean statefulRetry) {
211213
this.statefulRetry = statefulRetry;
212214
}

Diff for: spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java

+12
Original file line numberDiff line numberDiff line change
@@ -344,6 +344,11 @@ public void setRetryTemplate(RetryTemplate retryTemplate) {
344344
this.retryTemplate = retryTemplate;
345345
}
346346

347+
/**
348+
* Get the recovery callback.
349+
* @deprecated since 2.8 - use a suitably configured error handler instead.
350+
* @return the recovery callback.
351+
*/
347352
@Deprecated
348353
@Nullable
349354
protected RecoveryCallback<?> getRecoveryCallback() {
@@ -360,6 +365,11 @@ public void setRecoveryCallback(RecoveryCallback<? extends Object> recoveryCallb
360365
this.recoveryCallback = recoveryCallback;
361366
}
362367

368+
/**
369+
* @deprecated since 2.8 - use a suitably configured error handler instead.
370+
* @return
371+
*/
372+
@Deprecated
363373
protected boolean isStatefulRetry() {
364374
return this.statefulRetry;
365375
}
@@ -372,7 +382,9 @@ protected boolean isStatefulRetry() {
372382
* alive.
373383
* @param statefulRetry true to enable stateful retry.
374384
* @since 2.1.3
385+
* @deprecated since 2.8 - use a suitably configured error handler instead.
375386
*/
387+
@Deprecated
376388
public void setStatefulRetry(boolean statefulRetry) {
377389
this.statefulRetry = statefulRetry;
378390
}

0 commit comments

Comments
 (0)