Fix Previous Commit

garyrussell · garyrussell · commit b322a0da4bd4 · 2020-06-18T11:03:45.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/RecoveringBatchErrorHandler.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/RecoveringBatchErrorHandler.java
@@ -195,8 +195,8 @@ private void commit(Consumer<?, ?> consumer, MessageListenerContainer container,
 	}
 
 	private BatchListenerFailedException getBatchListenerFailedException(Throwable throwableArg) {
-		if (throwable == null || throwable instanceof BatchListenerFailedException) {
-			return (BatchListenerFailedException) throwable;
+		if (throwableArg == null || throwableArg instanceof BatchListenerFailedException) {
+			return (BatchListenerFailedException) throwableArg;
 		}
 
 		BatchListenerFailedException target = null;

Original file line number	Diff line number	Diff line change
`@@ -195,8 +195,8 @@ private void commit(Consumer<?, ?> consumer, MessageListenerContainer container,`
`195`	`195`	`}`
`196`	`196`
`197`	`197`	`private BatchListenerFailedException getBatchListenerFailedException(Throwable throwableArg) {`
`198`		`- if (throwable == null \|\| throwable instanceof BatchListenerFailedException) {`
`199`		`- return (BatchListenerFailedException) throwable;`
	`198`	`+ if (throwableArg == null \|\| throwableArg instanceof BatchListenerFailedException) {`
	`199`	`+ return (BatchListenerFailedException) throwableArg;`
`200`	`200`	`}`
`201`	`201`
`202`	`202`	`BatchListenerFailedException target = null;`