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

Remove setting required groups

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-05-18 16:44:23 +02:00
parent 6a039a57e4
commit 6ef016367c
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java
View File

@@ -163,7 +163,6 @@ public final class StreamBridge implements SmartInitializingSingleton {
SubscribableChannel resolveDestination(String destinationName, ProducerProperties producerProperties) {
SubscribableChannel messageChannel = this.channelCache.get(destinationName);
if (messageChannel == null) {
producerProperties.setRequiredGroups(destinationName);
messageChannel = new DirectWithAttributesChannel();
this.bindingService.bindProducer(messageChannel, destinationName, false);
this.channelCache.put(destinationName, messageChannel);