GH-690: Propagate AfterRollbackProcessor to child

garyrussell · artembilan · commit 247222415599 · 2018-06-13T14:08:55.000-04:00
Fixes #690 The concurrent container did not propagate its `AfterRollackProcessor` to child `KafkaMessageListenerContainer`s. **cherry-pick to 2.1.x, 2.0.x, 1.3.x** # Conflicts: # spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
@@ -136,6 +136,7 @@ protected void doStart() {
 					container.setApplicationEventPublisher(getApplicationEventPublisher());
 				}
 				container.setClientIdSuffix("-" + i);
+				container.setAfterRollbackProcessor(getAfterRollbackProcessor());
 				container.start();
 				this.containers.add(container);
 			}

Original file line number	Diff line number	Diff line change
`@@ -136,6 +136,7 @@ protected void doStart() {`
`136`	`136`	`container.setApplicationEventPublisher(getApplicationEventPublisher());`
`137`	`137`	`}`
`138`	`138`	`container.setClientIdSuffix("-" + i);`
	`139`	`+ container.setAfterRollbackProcessor(getAfterRollbackProcessor());`
`139`	`140`	`container.start();`
`140`	`141`	`this.containers.add(container);`
`141`	`142`	`}`