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

Addressed boot changes to RabbitProperties

Browse Source
This commit is contained in:
Oleg Zhurakousky
2017-11-22 16:55:07 -05:00
parent 2e8e51c4dd
commit 0542404f1a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java
View File

@@ -229,7 +229,7 @@ public class RabbitMessageChannelBinder
factory.setVirtualHost(config.determineVirtualHost());
}
if (config.getRequestedHeartbeat() != null) {
factory.setRequestedHeartbeat(config.getRequestedHeartbeat());
factory.setRequestedHeartbeat((int)config.getRequestedHeartbeat().getSeconds());
}
RabbitProperties.Ssl ssl = config.getSsl();
if (ssl.isEnabled()) {
@@ -243,7 +243,7 @@ public class RabbitMessageChannelBinder
factory.setTrustStorePassphrase(ssl.getTrustStorePassword());
}
if (config.getConnectionTimeout() != null) {
factory.setConnectionTimeout(config.getConnectionTimeout());
factory.setConnectionTimeout((int)config.getConnectionTimeout().getSeconds());
}
factory.afterPropertiesSet();