Skip to content

Commit f15a4c4

Browse files
committed
EnableIntegrationTests: increase receive timers
https://build.spring.io/browse/INT-MASTERSPRING40-623/
1 parent c6965b2 commit f15a4c4

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

spring-integration-core/src/test/java/org/springframework/integration/configuration/EnableIntegrationTests.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -585,13 +585,13 @@ public void testMetaAnnotations() {
585585
public void testBridgeAnnotations() {
586586
GenericMessage<?> testMessage = new GenericMessage<Object>("foo");
587587
this.bridgeInput.send(testMessage);
588-
Message<?> receive = this.bridgeOutput.receive(2000);
588+
Message<?> receive = this.bridgeOutput.receive(10_000);
589589
assertNotNull(receive);
590590
assertSame(receive, testMessage);
591591
assertNull(this.bridgeOutput.receive(10));
592592

593593
this.pollableBridgeInput.send(testMessage);
594-
receive = this.pollableBridgeOutput.receive(2000);
594+
receive = this.pollableBridgeOutput.receive(10_000);
595595
assertNotNull(receive);
596596
assertSame(receive, testMessage);
597597
assertNull(this.pollableBridgeOutput.receive(10));
@@ -609,21 +609,21 @@ public void testBridgeAnnotations() {
609609
Lifecycle.class).start();
610610

611611
this.metaBridgeInput.send(testMessage);
612-
receive = this.metaBridgeOutput.receive(2000);
612+
receive = this.metaBridgeOutput.receive(10_000);
613613
assertNotNull(receive);
614614
assertSame(receive, testMessage);
615615
assertNull(this.metaBridgeOutput.receive(10));
616616

617617
this.bridgeToInput.send(testMessage);
618-
receive = this.bridgeToOutput.receive(2000);
618+
receive = this.bridgeToOutput.receive(10_000);
619619
assertNotNull(receive);
620620
assertSame(receive, testMessage);
621621
assertNull(this.bridgeToOutput.receive(10));
622622

623623
PollableChannel replyChannel = new QueueChannel();
624624
Message<?> bridgeMessage = MessageBuilder.fromMessage(testMessage).setReplyChannel(replyChannel).build();
625625
this.pollableBridgeToInput.send(bridgeMessage);
626-
receive = replyChannel.receive(2000);
626+
receive = replyChannel.receive(10_000);
627627
assertNotNull(receive);
628628
assertSame(receive, bridgeMessage);
629629
assertNull(replyChannel.receive(10));
@@ -641,7 +641,7 @@ public void testBridgeAnnotations() {
641641
Lifecycle.class).start();
642642

643643
this.myBridgeToInput.send(bridgeMessage);
644-
receive = replyChannel.receive(2000);
644+
receive = replyChannel.receive(10_000);
645645
assertNotNull(receive);
646646
assertSame(receive, bridgeMessage);
647647
assertNull(replyChannel.receive(10));

0 commit comments

Comments
 (0)