diff --git a/advanced/dynamic-tcp-client/pom.xml b/advanced/dynamic-tcp-client/pom.xml index a79d069b..fa96220b 100644 --- a/advanced/dynamic-tcp-client/pom.xml +++ b/advanced/dynamic-tcp-client/pom.xml @@ -71,7 +71,7 @@ org.springframework.integration spring-integration-java-dsl - 1.2.0.RC1 + 1.2.0.RELEASE compile diff --git a/applications/file-split-ftp/pom.xml b/applications/file-split-ftp/pom.xml index 162c052a..c635fe31 100644 --- a/applications/file-split-ftp/pom.xml +++ b/applications/file-split-ftp/pom.xml @@ -94,7 +94,7 @@ org.springframework.integration spring-integration-java-dsl - 1.2.0.RC1 + 1.2.0.RELEASE compile diff --git a/applications/file-split-ftp/src/main/java/org/springframework/integration/samples/filesplit/Application.java b/applications/file-split-ftp/src/main/java/org/springframework/integration/samples/filesplit/Application.java index b0aa7d5a..5efe85d8 100644 --- a/applications/file-split-ftp/src/main/java/org/springframework/integration/samples/filesplit/Application.java +++ b/applications/file-split-ftp/src/main/java/org/springframework/integration/samples/filesplit/Application.java @@ -31,6 +31,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.integration.dsl.IntegrationFlow; import org.springframework.integration.dsl.IntegrationFlows; import org.springframework.integration.dsl.core.Pollers; +import org.springframework.integration.dsl.file.FileWritingMessageHandlerSpec; import org.springframework.integration.dsl.file.Files; import org.springframework.integration.dsl.mail.Mail; import org.springframework.integration.file.FileHeaders; @@ -62,7 +63,7 @@ public class Application { /** * Poll for files, add an error channel, split into lines route the start/end markers - * to {@link #markers()} and the lines to {@link #lines()}. + * to {@link #markers()} and the lines to {@link #lines}. * @return the flow. */ @Bean @@ -84,17 +85,16 @@ public class Application { * @return the flow. */ @Bean - public IntegrationFlow lines() { - return f -> f.handle(fileOut()); + public IntegrationFlow lines(FileWritingMessageHandler fileOut) { + return f -> f.handle(fileOut); } @Bean - public FileWritingMessageHandler fileOut() { + public FileWritingMessageHandlerSpec fileOut() { return Files.outboundAdapter("'/tmp/out'") .appendNewLine(true) - .fileNameGenerator(m -> m.getPayload().toString().substring(1, 4) + ".txt") - .fileExistsMode(FileExistsMode.APPEND_NO_FLUSH) // files remain open for efficiency - .get(); + .fileNameExpression("payload.substring(1, 4) + '.txt'") + .fileExistsMode(FileExistsMode.APPEND_NO_FLUSH); // files remain open for efficiency } /** diff --git a/basic/mqtt/pom.xml b/basic/mqtt/pom.xml index b82bfebc..8be7e303 100644 --- a/basic/mqtt/pom.xml +++ b/basic/mqtt/pom.xml @@ -77,7 +77,7 @@ org.springframework.integration spring-integration-java-dsl - 1.2.0.RC1 + 1.2.0.RELEASE compile diff --git a/dsl/cafe-dsl/pom.xml b/dsl/cafe-dsl/pom.xml index 820d776e..ed21b443 100644 --- a/dsl/cafe-dsl/pom.xml +++ b/dsl/cafe-dsl/pom.xml @@ -83,7 +83,7 @@ org.springframework.integration spring-integration-java-dsl - 1.2.0.RC1 + 1.2.0.RELEASE compile diff --git a/dsl/kafka-dsl/pom.xml b/dsl/kafka-dsl/pom.xml index 12c6ac77..628c243e 100644 --- a/dsl/kafka-dsl/pom.xml +++ b/dsl/kafka-dsl/pom.xml @@ -71,7 +71,7 @@ org.springframework.integration spring-integration-java-dsl - 1.2.0.RC1 + 1.2.0.RELEASE compile diff --git a/dsl/si4demo/pom.xml b/dsl/si4demo/pom.xml index f123ba6d..38253088 100644 --- a/dsl/si4demo/pom.xml +++ b/dsl/si4demo/pom.xml @@ -90,7 +90,7 @@ org.springframework.integration spring-integration-java-dsl - 1.2.0.RC1 + 1.2.0.RELEASE compile