When FailureMode is retry, queue even when inactive.

This is *most* of the implementation of FailureMode.Retry.
dustin · Feb 11, 2009 · 4caa1df · 4caa1df
1 parent cf4b55f
commit 4caa1df
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/net/spy/memcached/MemcachedConnection.java b/src/main/java/net/spy/memcached/MemcachedConnection.java
@@ -467,7 +467,7 @@ NodeLocator getLocator() {
 	public void addOperation(final String key, final Operation o) {
 		MemcachedNode placeIn=null;
 		MemcachedNode primary = locator.getPrimary(key);
-		if(primary.isActive()) {
+		if(primary.isActive() || failureMode == FailureMode.Retry) {
 			placeIn=primary;
 		} else {
 			// Look for another node in sequence that is ready.