diff --git a/spring-integration/pom.xml b/spring-integration/pom.xml
index abf5cfb3d6..315f549c12 100644
--- a/spring-integration/pom.xml
+++ b/spring-integration/pom.xml
@@ -17,7 +17,6 @@
-
org.springframework.integration
spring-integration-core
@@ -29,11 +28,6 @@
${javax-activation.version}
true
-
- javax.mail
- mail
- ${javax-mail.version}
-
org.springframework.integration
spring-integration-twitter
@@ -85,16 +79,21 @@
h2
${h2.version}
-
- javax.xml.bind
- jaxb-api
- ${jaxb-api.version}
-
org.postgresql
postgresql
${postgresql.version}
+
+ com.fasterxml.jackson.core
+ jackson-databind
+ ${jackson.version}
+
+
+ com.sun.mail
+ jakarta.mail
+ ${jakarta.mail.version}
+
@@ -124,14 +123,13 @@
- 5.1.13.RELEASE
+ 6.0.0
1.1.4.RELEASE
5.0.13.RELEASE
- 1.4.7
1.1.1
2.10
- 2.3.0
42.3.8
+ 2.0.1
\ No newline at end of file
diff --git a/spring-integration/src/main/java/com/baeldung/dsl/JavaDSLFileCopyConfig.java b/spring-integration/src/main/java/com/baeldung/dsl/JavaDSLFileCopyConfig.java
index adaeac5386..8afd39e9ab 100644
--- a/spring-integration/src/main/java/com/baeldung/dsl/JavaDSLFileCopyConfig.java
+++ b/spring-integration/src/main/java/com/baeldung/dsl/JavaDSLFileCopyConfig.java
@@ -1,6 +1,7 @@
package com.baeldung.dsl;
import java.io.File;
+import java.time.Duration;
import java.util.Scanner;
import java.util.concurrent.TimeUnit;
@@ -14,7 +15,6 @@ import org.springframework.integration.config.EnableIntegration;
import org.springframework.integration.core.GenericSelector;
import org.springframework.integration.core.MessageSource;
import org.springframework.integration.dsl.IntegrationFlow;
-import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.dsl.Pollers;
import org.springframework.integration.dsl.MessageChannels;
import org.springframework.integration.file.FileReadingMessageSource;
@@ -69,7 +69,7 @@ public class JavaDSLFileCopyConfig {
@Bean
public IntegrationFlow fileMover() {
- return IntegrationFlows.from(sourceDirectory(), configurer -> configurer.poller(Pollers.fixedDelay(10000)))
+ return IntegrationFlow.from(sourceDirectory(), configurer -> configurer.poller(Pollers.fixedDelay(10000)))
.filter(onlyJpgs())
.handle(targetDirectory())
.get();
@@ -77,7 +77,7 @@ public class JavaDSLFileCopyConfig {
// @Bean
public IntegrationFlow fileMoverWithLambda() {
- return IntegrationFlows.from(sourceDirectory(), configurer -> configurer.poller(Pollers.fixedDelay(10000)))
+ return IntegrationFlow.from(sourceDirectory(), configurer -> configurer.poller(Pollers.fixedDelay(10000)))
.filter(message -> ((File) message).getName()
.endsWith(".jpg"))
.handle(targetDirectory())
@@ -92,7 +92,7 @@ public class JavaDSLFileCopyConfig {
// @Bean
public IntegrationFlow fileMoverWithPriorityChannel() {
- return IntegrationFlows.from(sourceDirectory())
+ return IntegrationFlow.from(sourceDirectory())
.filter(onlyJpgs())
.channel("alphabetically")
.handle(targetDirectory())
@@ -113,7 +113,7 @@ public class JavaDSLFileCopyConfig {
// @Bean
public IntegrationFlow fileReader() {
- return IntegrationFlows.from(sourceDirectory(), configurer -> configurer.poller(Pollers.fixedDelay(10)))
+ return IntegrationFlow.from(sourceDirectory(), configurer -> configurer.poller(Pollers.fixedDelay(10)))
.filter(onlyJpgs())
.channel("holdingTank")
.get();
@@ -121,16 +121,16 @@ public class JavaDSLFileCopyConfig {
// @Bean
public IntegrationFlow fileWriter() {
- return IntegrationFlows.from("holdingTank")
- .bridge(e -> e.poller(Pollers.fixedRate(1, TimeUnit.SECONDS, 20)))
+ return IntegrationFlow.from("holdingTank")
+ .bridge(e -> e.poller(Pollers.fixedRate(Duration.of(1, TimeUnit.SECONDS.toChronoUnit()), Duration.of(20, TimeUnit.SECONDS.toChronoUnit()))))
.handle(targetDirectory())
.get();
}
// @Bean
public IntegrationFlow anotherFileWriter() {
- return IntegrationFlows.from("holdingTank")
- .bridge(e -> e.poller(Pollers.fixedRate(2, TimeUnit.SECONDS, 10)))
+ return IntegrationFlow.from("holdingTank")
+ .bridge(e -> e.poller(Pollers.fixedRate(Duration.of(2, TimeUnit.SECONDS.toChronoUnit()), Duration.of(10, TimeUnit.SECONDS.toChronoUnit()))))
.handle(anotherTargetDirectory())
.get();
}