Upgrade ActiveMQ and extend timeout in STOMP tests

Author: bclozel

build.gradle

@@ -95,7 +95,7 @@ configure(allprojects) { project ->
 			dependency "commons-io:commons-io:2.5"
 			dependency "io.vavr:vavr:0.10.3"
 			dependency "net.sf.jopt-simple:jopt-simple:5.0.4"
-			dependencySet(group: 'org.apache.activemq', version: '5.8.0') {
+			dependencySet(group: 'org.apache.activemq', version: '5.16.0') {
 				entry 'activemq-broker'
 				entry('activemq-kahadb-store') {
 					exclude group: "org.springframework", name: "spring-context"

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

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

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

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