[camel] branch camel-2.22.x updated: CAMEL-12720: Krati implementation does not work properly persistence after put operation

[dmvolod]

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

dmvolod pushed a commit to branch camel-2.22.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-2.22.x by this push:
     new 5972451  CAMEL-12720: Krati implementation does not work properly 
persistence after put operation
5972451 is described below

commit 5972451cf56d7a230cb308e70c781309dca06f59
Author: Dmitry Volodin <dmvo...@gmail.com>
AuthorDate: Tue Aug 14 11:32:51 2018 +0300

    CAMEL-12720: Krati implementation does not work properly persistence
    after put operation
---
 .../src/main/java/org/apache/camel/component/krati/KratiProducer.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiProducer.java
 
b/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiProducer.java
index 50e9f8d..61134ca 100644
--- 
a/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiProducer.java
+++ 
b/components/camel-krati/src/main/java/org/apache/camel/component/krati/KratiProducer.java
@@ -78,6 +78,7 @@ public class KratiProducer extends DefaultProducer {
             //Its required to have only one thread putting stuff there at any 
given time per store.
             synchronized (endpoint.getPath().intern()) {
                 dataStore.put(key, value);
+                dataStore.persist();
             }
         }
     }