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

Move XSD to 3.0 version

Browse Source 
* Upgrade to Gradle 3.2
* Increase timeout in the `KafkaTests`
This commit is contained in:
Artem Bilan
2016-11-16 11:57:13 -05:00
committed by Artem Bilan
parent 598eb7f80e
commit 87561e565f
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-kafka/src/main/resources/META-INF/spring.schemas
View File

@@ -1,2 +1,2 @@
http\://www.springframework.org/schema/integration/kafka/spring-integration-kafka-2.1.xsd=org/springframework/integration/kafka/config/spring-integration-kafka-2.1.xsd
http\://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd=org/springframework/integration/kafka/config/spring-integration-kafka-2.1.xsd
http\://www.springframework.org/schema/integration/kafka/spring-integration-kafka-3.0.xsd=org/springframework/integration/kafka/config/spring-integration-kafka-3.0.xsd
http\://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd=org/springframework/integration/kafka/config/spring-integration-kafka-3.0.xsd

0
spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-2.1.xsd → spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.0.xsd
View File

2
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaTests.java
View File

@@ -108,7 +108,7 @@ public class KafkaTests {
this.sendToKafkaFlowInput.send(new GenericMessage<>("foo"));
for (int i = 0; i < 100; i++) {
Message<?> receive = this.listeningFromKafkaResults.receive(10000);
Message<?> receive = this.listeningFromKafkaResults.receive(20000);
assertThat(receive).isNotNull();
assertThat(receive.getPayload()).isEqualTo("FOO");
MessageHeaders headers = receive.getHeaders();