[camel] branch master updated: CAMEL-13272: File producer - Issue with toD when using moveExisting

[davsclaus]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new d202ee2  CAMEL-13272: File producer - Issue with toD when using 
moveExisting
d202ee2 is described below

commit d202ee2e03541bdf1e9ae1f3be3b8fd665fd57df
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Feb 28 08:21:37 2019 +0100

    CAMEL-13272: File producer - Issue with toD when using moveExisting
---
 .../file/GenericFileSendDynamicAware.java          | 23 +++++++++++++++++++++-
 1 file changed, 22 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileSendDynamicAware.java
 
b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileSendDynamicAware.java
index 2d54745..b3d5d3e 100644
--- 
a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileSendDynamicAware.java
+++ 
b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileSendDynamicAware.java
@@ -49,16 +49,37 @@ public abstract class GenericFileSendDynamicAware 
implements SendDynamicAware {
 
     @Override
     public String resolveStaticUri(Exchange exchange, DynamicAwareEntry entry) 
throws Exception {
+        boolean fileName = entry.getProperties().containsKey("fileName");
+        boolean tempFileName = 
entry.getProperties().containsKey("tempFileName");
+        boolean idempotentKey = 
entry.getProperties().containsKey("idempotentKey");
         boolean move = entry.getProperties().containsKey("move");
         boolean moveFailed = entry.getProperties().containsKey("moveFailed");
         boolean preMove = entry.getProperties().containsKey("preMove");
         boolean moveExisting = 
entry.getProperties().containsKey("moveExisting");
         // if any of the above are in use, then they should not be pre 
evaluated
         // and we need to rebuild a new uri with them as-is
-        if (move || moveFailed || preMove || moveExisting) {
+        if (fileName || tempFileName || idempotentKey || move || moveFailed || 
preMove || moveExisting) {
             Map<String, String> params = new 
LinkedHashMap<>(entry.getProperties());
 
             Map<String, Object> originalParams = 
URISupport.parseQuery(entry.getOriginalUri());
+            if (fileName) {
+                Object val = originalParams.get("fileName");
+                if (val != null) {
+                    params.put("fileName", val.toString());
+                }
+            }
+            if (tempFileName) {
+                Object val = originalParams.get("tempFileName");
+                if (val != null) {
+                    params.put("tempFileName", val.toString());
+                }
+            }
+            if (idempotentKey) {
+                Object val = originalParams.get("idempotentKey");
+                if (val != null) {
+                    params.put("idempotentKey", val.toString());
+                }
+            }
             if (move) {
                 Object val = originalParams.get("move");
                 if (val != null) {