add consistencyLevel to callback in mutateCounter
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/56b0e7bb Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/56b0e7bb Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/56b0e7bb Branch: refs/heads/cassandra-2.0 Commit: 56b0e7bbbd9223830ff755684a1a7113d083539b Parents: d245c35 Author: Jonathan Ellis <jbel...@apache.org> Authored: Fri Oct 4 16:36:31 2013 -0500 Committer: Jonathan Ellis <jbel...@apache.org> Committed: Fri Oct 4 16:36:31 2013 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/service/StorageProxy.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/56b0e7bb/src/java/org/apache/cassandra/service/StorageProxy.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java index 8d01281..0a6de48 100644 --- a/src/java/org/apache/cassandra/service/StorageProxy.java +++ b/src/java/org/apache/cassandra/service/StorageProxy.java @@ -1039,7 +1039,9 @@ public class StorageProxy implements StorageProxyMBean AbstractWriteResponseHandler responseHandler = new WriteResponseHandler(endpoint, WriteType.COUNTER); Tracing.trace("Enqueuing counter update to {}", endpoint); - MessagingService.instance().sendRR(cm.makeMutationMessage(), endpoint, responseHandler); + MessageOut<CounterMutation> message = cm.makeMutationMessage(); + int id = MessagingService.instance().addCallback(responseHandler, message, endpoint, message.getTimeout(), cm.consistency()); + MessagingService.instance().sendOneWay(message, id, endpoint); return responseHandler; } }
