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

Fix RabbitMQ spring connector tests when run against RabbitMQ client 5.4.x.

Browse Source
This commit is contained in:
Scott Frederick
2018-09-11 14:44:53 -05:00
parent bd6adf6177
commit d0d80ce5a2
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
build.gradle
View File

@@ -223,6 +223,7 @@ ext {
"amqp14" : [springAmqpVersion: "1.4.6.RELEASE"],
"amqp15" : [springAmqpVersion: "1.5.6.RELEASE"],
"amqp16" : [springAmqpVersion: "1.6.0.RELEASE"],
"amqp20" : [springAmqpVersion: "2.0.0.RELEASE"],
"spring32" : [springVersion: "3.2.17.RELEASE"],
"spring40" : [springVersion: "4.0.9.RELEASE"],
"spring41" : [springVersion: "4.1.9.RELEASE"],

4
spring-cloud-spring-service-connector/src/test/java/org/springframework/cloud/service/rabbit/RabbitConnectionFactoryCreatorTest.java
View File

@@ -76,8 +76,8 @@ public class RabbitConnectionFactoryCreatorTest {
com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory =
(com.rabbitmq.client.ConnectionFactory) ReflectionTestUtils.getField(connector, "rabbitConnectionFactory");
String[] userInfo = uri.getRawUserInfo().split(":");
assertEquals(userInfo[0], ReflectionTestUtils.getField(rabbitConnectionFactory, "username"));
assertEquals(userInfo[1], ReflectionTestUtils.getField(rabbitConnectionFactory, "password"));
assertEquals(userInfo[0], rabbitConnectionFactory.getUsername());
assertEquals(userInfo[1], rabbitConnectionFactory.getPassword());
assertTrue(uri.getPath().endsWith(connector.getVirtualHost()));
}