org.apache.cassandra.service
Class QuorumResponseHandler<T>
java.lang.Object
org.apache.cassandra.service.QuorumResponseHandler<T>
- All Implemented Interfaces:
- IAsyncCallback
public class QuorumResponseHandler<T>
- 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
QuorumResponseHandler
public QuorumResponseHandler(int responseCount,
IResponseResolver<T> responseResolver)
get
public T get()
throws java.util.concurrent.TimeoutException,
DigestMismatchException,
java.io.IOException
- Throws:
java.util.concurrent.TimeoutException
DigestMismatchException
java.io.IOException
response
public void response(Message message)
- Specified by:
response
in interface IAsyncCallback
- Parameters:
message
- response received.
Copyright © 2010 The Apache Software Foundation