Updated Branches: refs/heads/master c4e503ad8 -> d2ea01654
CAMEL-6554: Added sync option to LevelDBAggregationRepository to make it easy to configure Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d2ea0165 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d2ea0165 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d2ea0165 Branch: refs/heads/master Commit: d2ea016543223b142e8ed15d93eeda86c9a2d5c3 Parents: c4e503a Author: Claus Ibsen <davscl...@apache.org> Authored: Wed Jul 17 10:29:33 2013 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Jul 17 10:29:33 2013 +0200 ---------------------------------------------------------------------- .../component/leveldb/LevelDBAggregationRepository.java | 10 ++++++++++ 1 file changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/d2ea0165/components/camel-leveldb/src/main/java/org/apache/camel/component/leveldb/LevelDBAggregationRepository.java ---------------------------------------------------------------------- diff --git a/components/camel-leveldb/src/main/java/org/apache/camel/component/leveldb/LevelDBAggregationRepository.java b/components/camel-leveldb/src/main/java/org/apache/camel/component/leveldb/LevelDBAggregationRepository.java index 6033b54..72ad0e3 100644 --- a/components/camel-leveldb/src/main/java/org/apache/camel/component/leveldb/LevelDBAggregationRepository.java +++ b/components/camel-leveldb/src/main/java/org/apache/camel/component/leveldb/LevelDBAggregationRepository.java @@ -47,6 +47,7 @@ public class LevelDBAggregationRepository extends ServiceSupport implements Reco private LevelDBFile levelDBFile; private String persistentFileName; private String repositoryName; + private boolean sync; private boolean returnOldExchange; private LevelDBCamelCodec codec = new LevelDBCamelCodec(); private long recoveryInterval = 5000; @@ -337,6 +338,14 @@ public class LevelDBAggregationRepository extends ServiceSupport implements Reco this.repositoryName = repositoryName; } + public boolean isSync() { + return sync; + } + + public void setSync(boolean sync) { + this.sync = sync; + } + public boolean isReturnOldExchange() { return returnOldExchange; } @@ -395,6 +404,7 @@ public class LevelDBAggregationRepository extends ServiceSupport implements Reco // either we have a LevelDB configured or we use a provided fileName if (levelDBFile == null && persistentFileName != null) { levelDBFile = new LevelDBFile(); + levelDBFile.setSync(isSync()); levelDBFile.setFileName(persistentFileName); }
