RabbitMessageChannelBinder fails to initialize LocalizedQueueConnectionFactory if ssl.enabled is not specified #2331
Comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
{{ message }}
@vkochnev commented on Wed Nov 03 2021
https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/blob/09c8b9bdc5a172b4034b32ff4d70b094ccb616b7/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java#L262
Shouldn't it be
this.rabbitProperties.getSsl().determineEnabled()instead? The problem is ifspring.rabbitmq.ssl.enabledis not specified inapplication.ymlthis line fails with NPE.Also if
virtualHost,usernameand/orpasswordare specified on addresses instead of separate fields current implementation will ignore them, use ofdetermine*alternatives might help here also (It looks like I should file these separately, but I'm not sure it makes sense).More comprehensive solution might be discussed in spring-projects/spring-amqp#1384
The text was updated successfully, but these errors were encountered: