Make container.getAfterRollbackProcessor() public

garyrussell · garyrussell · commit d76a4fa2831c · 2020-05-20T09:53:56.000-04:00
Resolves spring-attic/spring-cloud-stream-binder-kafka#900
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java
@@ -227,7 +227,12 @@ public int getPhase() {
 		return this.phase;
 	}
 
-	protected AfterRollbackProcessor<? super K, ? super V> getAfterRollbackProcessor() {
+	/**
+	 * Return the currently configured {@link AfterRollbackProcessor}.
+	 * @return the after rollback processor.
+	 * @since 2.2.14
+	 */
+	public AfterRollbackProcessor<? super K, ? super V> getAfterRollbackProcessor() {
 		return this.afterRollbackProcessor;
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -227,7 +227,12 @@ public int getPhase() {`
`227`	`227`	`return this.phase;`
`228`	`228`	`}`
`229`	`229`
`230`		`- protected AfterRollbackProcessor<? super K, ? super V> getAfterRollbackProcessor() {`
	`230`	`+ /**`
	`231`	`+ * Return the currently configured {@link AfterRollbackProcessor}.`
	`232`	`+ * @return the after rollback processor.`
	`233`	`+ * @since 2.2.14`
	`234`	`+ */`
	`235`	`+ public AfterRollbackProcessor<? super K, ? super V> getAfterRollbackProcessor() {`
`231`	`236`	`return this.afterRollbackProcessor;`
`232`	`237`	`}`
`233`	`238`