[camel] branch main updated: CAMEL-18130: camel-file/camel-ftp - Route with last processor setting OUT message causes file/ftp to not be moved correctly when its uow is done. Thanks to Manuel Shenavai for reporting and unit test.

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 4127d531058 CAMEL-18130: camel-file/camel-ftp - Route with last 
processor setting OUT message causes file/ftp to not be moved correctly when 
its uow is done. Thanks to Manuel Shenavai for reporting and unit test.
4127d531058 is described below

commit 4127d531058cb03643b83fbea7838daa3b9bfb28
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon May 23 09:15:43 2022 +0200

    CAMEL-18130: camel-file/camel-ftp - Route with last processor setting OUT 
message causes file/ftp to not be moved correctly when its uow is done. Thanks 
to Manuel Shenavai for reporting and unit test.
---
 .../org/apache/camel/component/file/FileMoveWithInMessageTest.java    | 4 ++--
 .../org/apache/camel/component/file/FileMoveWithOutMessageTest.java   | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithInMessageTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithInMessageTest.java
index 2f0b47cabee..b55e4f2d969 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithInMessageTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithInMessageTest.java
@@ -38,7 +38,7 @@ public class FileMoveWithInMessageTest extends 
ContextTestSupport {
         template.sendBodyAndHeader(uri, "Hello World2", Exchange.FILE_NAME, 
"hello2.txt");
 
         // trigger
-        template.sendBody("vm:trigger", "");
+        template.sendBody("seda:triggerIn", "");
 
         File file1 = new File(testDirectory().toFile(), "archive/hello1.txt");
         await().atMost(10, TimeUnit.SECONDS)
@@ -54,7 +54,7 @@ public class FileMoveWithInMessageTest extends 
ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("vm:trigger")
+                from("seda:triggerIn")
                         .pollEnrich(fileUri() + "?move=archive")
                         .pollEnrich(fileUri() + "?move=archive")
                         .process(new TestProcessor());
diff --git 
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithOutMessageTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithOutMessageTest.java
index a888b7e8657..3fb297488c7 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithOutMessageTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileMoveWithOutMessageTest.java
@@ -38,7 +38,7 @@ public class FileMoveWithOutMessageTest extends 
ContextTestSupport {
         template.sendBodyAndHeader(uri, "Hello World2", Exchange.FILE_NAME, 
"hello2.txt");
 
         // trigger
-        template.sendBody("vm:trigger", "");
+        template.sendBody("seda:triggerOut", "");
 
         File file1 = new File(testDirectory().toFile(), "archive/hello1.txt");
         await().atMost(10, TimeUnit.SECONDS)
@@ -54,7 +54,7 @@ public class FileMoveWithOutMessageTest extends 
ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("vm:trigger")
+                from("seda:triggerOut")
                         .pollEnrich(fileUri() + "?move=archive")
                         .pollEnrich(fileUri() + "?move=archive")
                         .process(new TestProcessor());