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

Fix rabbit sink IT OwnConnectionTest

Browse Source 
* Check boot connection factory destroyed earlier in test
* Check rabbit template not using boot connection factory
This commit is contained in:
onobc
2022-01-27 20:33:46 -06:00
committed by Soby Chacko
parent 5c7a764326
commit 5d1fd5db58
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/OwnConnectionTest.java
View File

@@ -25,6 +25,10 @@ import org.springframework.test.context.TestPropertySource;
import static org.assertj.core.api.Assertions.assertThat;
/**
* @author Soby Chacko
* @author Chris Bono
*/
@TestPropertySource(properties = {"rabbit.routingKey=scsapp-testOwn",
"rabbit.own-connection=true"})
public class OwnConnectionTest extends RabbitSinkIntegrationTests {
@@ -33,12 +37,18 @@ public class OwnConnectionTest extends RabbitSinkIntegrationTests {
public void test() {
this.rabbitAdmin.declareQueue(
new Queue("scsapp-testOwn", false, false, true));
this.bootFactory.resetConnection();
this.channels.send(MessageBuilder.withPayload("foo".getBytes())
.build());
// Destroy the boot connection factory - should not matter to outbound adapter as it SHOULD be using its own connection factory
this.bootFactory.destroy();
assertThat(this.bootFactory.getCacheProperties().getProperty("localPort")).isEqualTo("0");
// Send to the channel - should still be consumed by outbound adapter as its using its own connection factory
this.channels.send(MessageBuilder.withPayload("foo".getBytes()).build());
// RabbitTemplate also using its own connection factory - should still be able to get the message
assertThat(this.rabbitTemplate.getConnectionFactory()).isNotSameAs(bootFactory);
this.rabbitTemplate.setReceiveTimeout(10000);
Message received = this.rabbitTemplate.receive("scsapp-testOwn");
assertThat(new String(received.getBody())).isEqualTo("foo");
assertThat(this.bootFactory.getCacheProperties().getProperty("localPort")).isEqualTo("0");
}
}