diff --git a/core/src/main/java/de/javakaffee/web/msm/MemcachedSessionService.java b/core/src/main/java/de/javakaffee/web/msm/MemcachedSessionService.java index 7dc57e4a..99ed8608 100644 --- a/core/src/main/java/de/javakaffee/web/msm/MemcachedSessionService.java +++ b/core/src/main/java/de/javakaffee/web/msm/MemcachedSessionService.java @@ -62,6 +62,7 @@ import de.javakaffee.web.msm.BackupSessionTask.BackupResult; import de.javakaffee.web.msm.LockingStrategy.LockingMode; import de.javakaffee.web.msm.MemcachedNodesManager.MemcachedClientCallback; +import net.spy.memcached.FailureMode; /** * This is the core of memcached session manager, managing sessions in memcached. @@ -497,6 +498,7 @@ protected MemcachedClient createMemcachedClient( final MemcachedNodesManager mem // And: http://code.google.com/p/spymemcached/wiki/Examples#Establishing_a_Membase_Connection final CouchbaseConnectionFactoryBuilder factory = new CouchbaseConnectionFactoryBuilder(); factory.setOpTimeout(_operationTimeout); + factory.setFailureMode(FailureMode.Redistribute); return new CouchbaseClient(factory.buildCouchbaseConnection(memcachedNodesManager.getCouchbaseBucketURIs(), _username, _password)); } final ConnectionFactory connectionFactory = createConnectionFactory(memcachedNodesManager, connectionType, statistics);