From 5edc910a7fc2dc377df21c8f0f7f6a3294081d70 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Tue, 12 Jan 2016 09:42:53 -0500 Subject: [PATCH] MQTT: Increase Test Timeouts --- .../integration/mqtt/BackToBackAdapterTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/BackToBackAdapterTests.java b/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/BackToBackAdapterTests.java index 5cba1ae340..096a39ccce 100644 --- a/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/BackToBackAdapterTests.java +++ b/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/BackToBackAdapterTests.java @@ -99,7 +99,7 @@ public class BackToBackAdapterTests { inbound.start(); adapter.handleMessage(new GenericMessage("foo")); adapter.stop(); - Message out = outputChannel.receive(1000); + Message out = outputChannel.receive(10000); assertNotNull(out); inbound.stop(); assertEquals("foo", out.getPayload()); @@ -138,7 +138,7 @@ public class BackToBackAdapterTests { inbound.removeTopic("mqtt-bar"); adapter.handleMessage(MessageBuilder.withPayload("bar").setHeader(MqttHeaders.TOPIC, "mqtt-bar").build()); - out = outputChannel.receive(1000); + out = outputChannel.receive(10000); assertNull(out); try { @@ -179,12 +179,12 @@ public class BackToBackAdapterTests { Message message = MessageBuilder.withPayload("bar").setHeader(MqttHeaders.TOPIC, "mqtt-bar").build(); adapter.handleMessage(message); adapter.stop(); - Message out = outputChannel.receive(1000); + Message out = outputChannel.receive(10000); assertNotNull(out); inbound.stop(); assertEquals("foo", out.getPayload()); assertEquals("mqtt-foo", out.getHeaders().get(MqttHeaders.TOPIC)); - out = outputChannel.receive(1000); + out = outputChannel.receive(10000); assertNotNull(out); inbound.stop(); assertEquals("bar", out.getPayload());