diff --git a/src/main/java/net/spy/memcached/MemcachedClient.java b/src/main/java/net/spy/memcached/MemcachedClient.java index 77d0f048e..10d01ec0b 100644 --- a/src/main/java/net/spy/memcached/MemcachedClient.java +++ b/src/main/java/net/spy/memcached/MemcachedClient.java @@ -280,12 +280,10 @@ public Transcoder getTranscoder() { return transcoder; } - @Override public CountDownLatch broadcastOp(final BroadcastOpFactory of) { return broadcastOp(of, mconn.getLocator().getAll(), true); } - @Override public CountDownLatch broadcastOp(final BroadcastOpFactory of, Collection nodes) { return broadcastOp(of, nodes, true); diff --git a/src/main/java/net/spy/memcached/MemcachedClientIF.java b/src/main/java/net/spy/memcached/MemcachedClientIF.java index 78992aa55..00cf7658e 100644 --- a/src/main/java/net/spy/memcached/MemcachedClientIF.java +++ b/src/main/java/net/spy/memcached/MemcachedClientIF.java @@ -24,7 +24,6 @@ package net.spy.memcached; import net.spy.memcached.internal.BulkFuture; -import net.spy.memcached.internal.OperationFuture; import net.spy.memcached.transcoders.Transcoder; import java.net.SocketAddress; @@ -32,7 +31,6 @@ import java.util.Iterator; import java.util.Map; import java.util.Set; -import java.util.concurrent.CountDownLatch; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; @@ -77,7 +75,7 @@ Future asyncCAS(String key, long casId, T value, Future asyncCAS(String key, long casId, int exp, Object value); - OperationFuture asyncCAS(String key, long casId, int exp, + Future asyncCAS(String key, long casId, int exp, T value, Transcoder tc); CASResponse cas(String key, long casId, int exp, T value, @@ -230,10 +228,6 @@ Future touch(final String key, final int exp, boolean removeObserver(ConnectionObserver obs); - CountDownLatch broadcastOp(final BroadcastOpFactory of); - CountDownLatch broadcastOp(final BroadcastOpFactory of, - Collection nodes); - /** * Get the set of SASL mechanisms supported by the servers. *