Added option to set max transactions.

1 files changed, 17 insertions, 0 deletions

diff --git a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java
index 7605b30..0c66487 100644
--- a/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java
+++ b/src/main/java/com/amazon/carbonado/repo/sleepycat/BDBRepositoryBuilder.java
@@ -97,6 +97,7 @@ public final class BDBRepositoryBuilder extends AbstractRepositoryBuilder {
     private double mTxnTimeout = 300.0;

     private boolean mTxnNoSync;

     private boolean mTxnWriteNoSync;

+    private Integer mTxnMaxActive;

     private Boolean mDatabasesTransactional = null;

     private boolean mReverseSplitOff;

     private Map<Class<?>, Integer> mDatabasePageSizes;

@@ -555,6 +556,22 @@ public final class BDBRepositoryBuilder extends AbstractRepositoryBuilder {
     }

 

     /**

+     * Set the maximum number of concurrent transactions, or pass null to use

+     * the default. This setting has no effect for BDB-JE.

+     */

+    public void setTransactionMaxActive(Integer max) {

+        mTxnMaxActive = max;

+    }

+

+    /**

+     * Returns the maximum number of concurrent transactions, or null if the

+     * default is used.

+     */

+    public Integer getTransactionMaxActive() {

+        return mTxnMaxActive;

+    }

+

+    /**

      * When true, allows databases to be transactional. This setting affects

      * the databases, not the environment. If this is not explicitly set, the

      * environment getTransactional is used.