root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Revert timeout inscreases in STOMP tests 

This change is not fixing tests but rather increasing their duration, so
we're reverting this change as a result.
This commit is contained in:
Brian Clozel 2020-08-08 16:39:56 +02:00
parent d0cf90bb8e
commit 88ccab8f13
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spring-messaging/src/test/java/org/springframework/messaging/simp/stomp/ReactorNettyTcpStompClientTests.java
View File

@ -106,8 +106,8 @@ public class ReactorNettyTcpStompClientTests {
ConsumingHandler consumingHandler2 = new ConsumingHandler(destination); ConsumingHandler consumingHandler2 = new ConsumingHandler(destination);
ListenableFuture<StompSession> consumerFuture2 = this.client.connect(consumingHandler2); ListenableFuture<StompSession> consumerFuture2 = this.client.connect(consumingHandler2);
assertThat(consumingHandler1.awaitForSubscriptions(10000)).isTrue(); assertThat(consumingHandler1.awaitForSubscriptions(5000)).isTrue();
assertThat(consumingHandler2.awaitForSubscriptions(10000)).isTrue(); assertThat(consumingHandler2.awaitForSubscriptions(5000)).isTrue();
ProducingHandler producingHandler = new ProducingHandler(); ProducingHandler producingHandler = new ProducingHandler();
producingHandler.addToSend(destination, "foo1"); producingHandler.addToSend(destination, "foo1");

2
spring-messaging/src/test/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandlerIntegrationTests.java
View File

@ -254,7 +254,7 @@ public class StompBrokerRelayMessageHandlerIntegrationTests {
} }
public void expectBrokerAvailabilityEvent(boolean isBrokerAvailable) throws InterruptedException { public void expectBrokerAvailabilityEvent(boolean isBrokerAvailable) throws InterruptedException {
BrokerAvailabilityEvent event = this.eventQueue.poll(40000, TimeUnit.MILLISECONDS); BrokerAvailabilityEvent event = this.eventQueue.poll(20000, TimeUnit.MILLISECONDS);
assertThat(event).as("Times out waiting for BrokerAvailabilityEvent[" + isBrokerAvailable + "]").isNotNull(); assertThat(event).as("Times out waiting for BrokerAvailabilityEvent[" + isBrokerAvailable + "]").isNotNull();
assertThat(event.isBrokerAvailable()).isEqualTo(isBrokerAvailable); assertThat(event.isBrokerAvailable()).isEqualTo(isBrokerAvailable);
} }