[jbosscache-commits] JBoss Cache SVN: r6123 - core/trunk/src/main/java/org/jboss/cache/config.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-06-30 09:32:24 -0400 (Mon, 30 Jun 2008)
New Revision: 6123

Modified:
   core/trunk/src/main/java/org/jboss/cache/config/Configuration.java
Log:
Added cfg options for allowing write skew and concurrency level

Modified: core/trunk/src/main/java/org/jboss/cache/config/Configuration.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/config/Configuration.java	2008-06-30 13:29:46 UTC (rev 6122)
+++ core/trunk/src/main/java/org/jboss/cache/config/Configuration.java	2008-06-30 13:32:24 UTC (rev 6123)
@@ -32,16 +32,6 @@
 
    private JGroupsStackParser jGroupsStackParser = new JGroupsStackParser();
 
-   public void setCacheMarshaller(Marshaller instance)
-   {
-      marshaller = instance;
-   }
-
-   public Marshaller getMarshaller()
-   {
-      return marshaller;
-   }
-
    /**
     * Behavior of the JVM shutdown hook registered by the cache
     */
@@ -211,11 +201,45 @@
    private int objectInputStreamPoolSize = 50;
    private int objectOutputStreamPoolSize = 50;
    private List<CustomInterceptorConfig> customInterceptors = Collections.emptyList();
+   private boolean allowWriteSkew = false;
+   private int concurrencyLevel = 50;
 
    // ------------------------------------------------------------------------------------------------------------
    //   SETTERS - MAKE SURE ALL SETTERS PERFORM testImmutability()!!!
    // ------------------------------------------------------------------------------------------------------------
 
+   public void setCacheMarshaller(Marshaller instance)
+   {
+      marshaller = instance;
+   }
+
+   public Marshaller getMarshaller()
+   {
+      return marshaller;
+   }
+
+   public boolean isAllowWriteSkew()
+   {
+      return allowWriteSkew;
+   }
+
+   public void setAllowWriteSkew(boolean allowWriteSkew)
+   {
+      testImmutability("allowWriteSkew");
+      this.allowWriteSkew = allowWriteSkew;
+   }
+
+   public int getConcurrencyLevel()
+   {
+      return concurrencyLevel;
+   }
+
+   public void setConcurrencyLevel(int concurrencyLevel)
+   {
+      testImmutability("concurrencyLevel");
+      this.concurrencyLevel = concurrencyLevel;
+   }
+
    /**
     * Converts a list of elements to a Java Groups property string.
     */