org.apache.cassandra.service
Class WriteResponseHandler
java.lang.Object
org.apache.cassandra.service.WriteResponseHandler
- All Implemented Interfaces:
- IAsyncCallback
public class WriteResponseHandler
- extends java.lang.Object
- implements IAsyncCallback
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected static final org.apache.log4j.Logger logger
condition
protected final SimpleCondition condition
responses
protected final java.util.Collection<Message> responses
localResponses
protected java.util.concurrent.atomic.AtomicInteger localResponses
WriteResponseHandler
public WriteResponseHandler(int responseCount,
java.lang.String table)
get
public void get()
throws java.util.concurrent.TimeoutException
- Throws:
java.util.concurrent.TimeoutException
response
public void response(Message message)
- Specified by:
response
in interface IAsyncCallback
- Parameters:
message
- response received.
localResponse
public void localResponse()
Copyright © 2010 The Apache Software Foundation