SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix message listener container bean naming

Browse Source 
With multiplex topics, topics can be an array. Sine message listener container
bean name is created by calling a toString() on the topics, when it is an array
it creates an unusual bean name. Fixing the issue by creating the bean name by
using destination string directly.
This commit is contained in:
Guillaume Lemont
2019-04-24 12:09:37 +02:00
committed by Soby Chacko
parent c990140452
commit c1f4cf9dc6
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
View File

@@ -535,7 +535,7 @@ public class KafkaMessageChannelBinder extends
messageListenerContainer
.setApplicationEventPublisher(getApplicationContext());
}
messageListenerContainer.setBeanName(topics + ".container");
messageListenerContainer.setBeanName(destination + ".container");
// end of these won't be needed...
if (!extendedConsumerProperties.getExtension().isAutoCommitOffset()) {
messageListenerContainer.getContainerProperties()