Modify method name.

spring-projects · Oct 10, 2024 · 08e7721 · 08e7721
1 parent 4a4a1ee
commit 08e7721
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 8 deletions.
diff --git a/...kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/...kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -906,7 +906,7 @@ else if (listener instanceof MessageListener) {
 								FailedRecordTuple<K, V> failedRecord = new FailedRecordTuple<>(cRecord, ex);
 								this.failedRecords.addLast(failedRecord);
 							};
-					this.listener.setCallbackForAsyncFailureQueue(callbackForAsyncFailureQueue);
+					this.listener.setCallbackForAsyncFailure(callbackForAsyncFailureQueue);
 				}
 			}
 			else {

diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/MessageListener.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/MessageListener.java
@@ -33,7 +33,7 @@
 @FunctionalInterface
 public interface MessageListener<K, V> extends GenericMessageListener<ConsumerRecord<K, V>> {
 
-	default void setCallbackForAsyncFailureQueue(
+	default void setCallbackForAsyncFailure(
 			BiConsumer<ConsumerRecord<K, V>, RuntimeException> asyncRetryCallback) {
 		//
 	}

diff --git a/...a/org/springframework/kafka/listener/adapter/KafkaBackoffAwareMessageListenerAdapter.java b/...a/org/springframework/kafka/listener/adapter/KafkaBackoffAwareMessageListenerAdapter.java
@@ -147,7 +147,7 @@ public void onMessage(ConsumerRecord<K, V> data, Consumer<?, ?> consumer) {
 	}
 
 	@Override
-	public void setCallbackForAsyncFailureQueue(BiConsumer<ConsumerRecord<K, V>, RuntimeException> callbackForAsyncFailureQueue) {
-		this.delegate.setCallbackForAsyncFailureQueue(callbackForAsyncFailureQueue);
+	public void setCallbackForAsyncFailure(BiConsumer<ConsumerRecord<K, V>, RuntimeException> callbackForAsyncFailureQueue) {
+		this.delegate.setCallbackForAsyncFailure(callbackForAsyncFailureQueue);
 	}
 }
diff --git a/...main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java b/...main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java
@@ -884,8 +884,8 @@ private boolean rawByParameterIsType(Type parameterType, Type type) {
 		return parameterType instanceof ParameterizedType pType && pType.getRawType().equals(type);
 	}
 
-	public void putInAsyncFailureQueue(BiConsumer<ConsumerRecord<K, V>, RuntimeException> callbackForAsyncFailureQueue) {
-		this.callbackForAsyncFailureQueue = callbackForAsyncFailureQueue;
+	protected void setCallbackForAsyncFailure(BiConsumer<ConsumerRecord<K, V>, RuntimeException> asyncRetryCallback) {
+		this.callbackForAsyncFailureQueue = asyncRetryCallback;
 	}
 
 	/**

diff --git a/...ava/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java b/...ava/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java
@@ -87,8 +87,8 @@ public void onMessage(ConsumerRecord<K, V> record, @Nullable Acknowledgment ackn
 	}
 
 	@Override
-	public void setCallbackForAsyncFailureQueue(
+	public void setCallbackForAsyncFailure(
 			BiConsumer<ConsumerRecord<K, V>, RuntimeException> asyncRetryCallback) {
-		putInAsyncFailureQueue(asyncRetryCallback);
+		super.setCallbackForAsyncFailure(asyncRetryCallback);
 	}
 }