Skip to content

Commit bf9ea9e

Browse files
committed
Fix Rabbit binder compiliation issues
1 parent d9326ad commit bf9ea9e

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,7 @@ public void onInit() throws Exception {
252252
super.onInit();
253253
if (this.clustered) {
254254
String[] addresses = StringUtils.commaDelimitedListToStringArray(
255-
this.rabbitProperties.getAddresses());
255+
StringUtils.collectionToDelimitedString(this.rabbitProperties.getAddresses(), ","));
256256

257257
Assert.state(
258258
addresses.length == this.adminAddresses.length

binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/RabbitBinderConfiguration.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,8 +72,9 @@ static void configureCachingConnectionFactory(
7272
ConfigurableApplicationContext applicationContext,
7373
RabbitProperties rabbitProperties) throws Exception {
7474

75-
if (StringUtils.hasText(rabbitProperties.getAddresses())) {
76-
connectionFactory.setAddresses(rabbitProperties.determineAddresses());
75+
String addressesText = StringUtils.collectionToDelimitedString(rabbitProperties.getAddresses(), ",");
76+
if (StringUtils.hasText(addressesText)) {
77+
connectionFactory.setAddresses(addressesText);
7778
}
7879

7980
connectionFactory.setPublisherConfirmType(rabbitProperties.getPublisherConfirmType() == null ? ConfirmType.NONE : rabbitProperties.getPublisherConfirmType());

0 commit comments

Comments
 (0)