Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix sporadic AMQP test failure

Browse Source 
https://build.spring.io/browse/INT-MASTER-1694

Use `receive(timeout)` on the AMQP channel and with 10 seconds interval
for the proper wait period instead of artificial short `do...while`
This commit is contained in:
Artem Bilan
2019-08-21 10:22:37 -04:00
parent 62d472f679
commit d26ee1db4a
1 changed files with 2 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-integration-amqp/src/test/java/org/springframework/integration/amqp/dsl/AmqpTests.java
View File

@@ -131,22 +131,11 @@ public class AmqpTests {
private PollableChannel amqpReplyChannel; private PollableChannel amqpReplyChannel;
@Test @Test
public void testAmqpOutboundFlow() throws Exception { public void testAmqpOutboundFlow() {
this.amqpOutboundInput.send(MessageBuilder.withPayload("hello through the amqp") this.amqpOutboundInput.send(MessageBuilder.withPayload("hello through the amqp")
.setHeader("routingKey", "si.dsl.test") .setHeader("routingKey", "si.dsl.test")
.build()); .build());
Message<?> receive = null; Message<?> receive = this.amqpReplyChannel.receive(10000);
int i = 0;
do {
receive = this.amqpReplyChannel.receive();
if (receive != null) {
break;
}
Thread.sleep(100);
i++;
}
while (i < 10);
assertThat(receive).isNotNull(); assertThat(receive).isNotNull();
assertThat(receive.getPayload()).isEqualTo("HELLO THROUGH THE AMQP"); assertThat(receive.getPayload()).isEqualTo("HELLO THROUGH THE AMQP");