Make container.getAfterRollbackProcessor() public

garyrussell · garyrussell · commit 1fefc1eadd4f · 2020-05-20T09:53:02.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
@@ -252,7 +252,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
`@@ -252,7 +252,12 @@ public int getPhase() {`
`252`	`252`	`return this.phase;`
`253`	`253`	`}`
`254`	`254`
`255`		`- protected AfterRollbackProcessor<? super K, ? super V> getAfterRollbackProcessor() {`
	`255`	`+ /**`
	`256`	`+ * Return the currently configured {@link AfterRollbackProcessor}.`
	`257`	`+ * @return the after rollback processor.`
	`258`	`+ * @since 2.2.14`
	`259`	`+ */`
	`260`	`+ public AfterRollbackProcessor<? super K, ? super V> getAfterRollbackProcessor() {`
`256`	`261`	`return this.afterRollbackProcessor;`
`257`	`262`	`}`
`258`	`263`