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

MQTT: Increase Test Timeouts

Browse Source
This commit is contained in:
Gary Russell
2016-01-12 09:42:53 -05:00
parent 6beaa2e89a
commit 5edc910a7f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/BackToBackAdapterTests.java
View File

@@ -99,7 +99,7 @@ public class BackToBackAdapterTests {
inbound.start();
adapter.handleMessage(new GenericMessage<String>("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());