Make container.getAfterRollbackProcessor() public

Resolves spring-cloud/spring-cloud-stream-binder-kafka#900
spring-projects · May 20, 2020 · 302a3bc · 302a3bc
1 parent 36992f8
commit 302a3bc
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...ka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java b/...ka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java
@@ -245,7 +245,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;
 	}