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

dmvolod 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 cbc487f  CAMEL-12720: Krati implementation does not work properly 
persistence after put operation
cbc487f is described below

commit cbc487f7b602703b5a0d2e97ad366c9ac26d47d3
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();
             }
         }
     }

Reply via email to