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

Polish previous commit

Browse Source 
Resolves #308
This commit is contained in:
Oleg Zhurakousky
2020-11-06 13:23:48 +01:00
parent 77e8f4f20b
commit 4fc390a5aa
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/RabbitMessageChannelBinderConfiguration.java
View File

@@ -22,6 +22,7 @@ import java.util.concurrent.atomic.AtomicInteger;
import org.springframework.amqp.core.DeclarableCustomizer;
import org.springframework.amqp.core.MessagePostProcessor;
import org.springframework.amqp.rabbit.connection.AbstractConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionNameStrategy;
import org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer;
import org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor;
@@ -46,6 +47,7 @@ import org.springframework.integration.amqp.inbound.AmqpMessageSource;
import org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint;
import org.springframework.lang.Nullable;
/**
* Configuration class for RabbitMQ message channel binder.
*
@@ -62,7 +64,7 @@ import org.springframework.lang.Nullable;
public class RabbitMessageChannelBinderConfiguration {
@Autowired
private AbstractConnectionFactory rabbitConnectionFactory;
private ConnectionFactory rabbitConnectionFactory;
@Autowired
private RabbitProperties rabbitProperties;
@@ -83,9 +85,9 @@ public class RabbitMessageChannelBinderConfiguration {
@Nullable ConnectionNameStrategy connectionNameStrategy) {
String connectionNamePrefix = this.rabbitBinderConfigurationProperties.getConnectionNamePrefix();
if (connectionNamePrefix != null && connectionNameStrategy == null) {
if (this.rabbitConnectionFactory instanceof AbstractConnectionFactory && connectionNamePrefix != null && connectionNameStrategy == null) {
final AtomicInteger nameIncrementer = new AtomicInteger();
this.rabbitConnectionFactory.setConnectionNameStrategy(f -> connectionNamePrefix
((AbstractConnectionFactory) this.rabbitConnectionFactory).setConnectionNameStrategy(f -> connectionNamePrefix
+ "#" + nameIncrementer.getAndIncrement());
}
RabbitMessageChannelBinder binder = new RabbitMessageChannelBinder(