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

INT-3881: MQTT: add XML recovery-intervalattr

Browse Source 
JIRA: https://jira.spring.io/browse/INT-3881

Also fix a couple typos in the WS xsd
This commit is contained in:
Artem Bilan
2016-01-14 13:36:35 -05:00
committed by Gary Russell
parent 84c5b7b193
commit b1a09f5b0d
6 changed files with 24 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/config/xml/MqttMessageDrivenChannelAdapterParserTests-context.xml
View File

@@ -15,6 +15,7 @@
client-id="foo"
url="tcp://localhost:1883"
client-factory="clientFactory"
recovery-interval="5000"
channel="out" />
<int-mqtt:message-driven-channel-adapter id="noTopicsAdapterDefaultCF"

4
spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/config/xml/MqttMessageDrivenChannelAdapterParserTests.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2015 the original author or authors.
* Copyright 2002-2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -36,6 +36,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
/**
* @author Gary Russell
* @author Artem Bilan
* @since 4.0
*
*/
@@ -78,6 +79,7 @@ public class MqttMessageDrivenChannelAdapterParserTests {
assertEquals(0, TestUtils.getPropertyValue(noTopicsAdapter, "topics", Collection.class).size());
assertSame(out, TestUtils.getPropertyValue(noTopicsAdapter, "outputChannel"));
assertSame(clientFactory, TestUtils.getPropertyValue(noTopicsAdapter, "clientFactory"));
assertEquals(5000, TestUtils.getPropertyValue(this.noTopicsAdapter, "recoveryInterval"));
}
@Test