[jbosscache-commits] JBoss Cache SVN: r6123 - core/trunk/src/main/java/org/jboss/cache/config.
Author: manik.surtani(a)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.
*/