You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2013/07/17 10:29:42 UTC
git commit: CAMEL-6554: Added sync option to
LevelDBAggregationRepository to make it easy to configure
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 <da...@apache.org>
Authored: Wed Jul 17 10:29:33 2013 +0200
Committer: Claus Ibsen <da...@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);
}