org.apache.cassandra.service
Class QuorumResponseHandler<T>

java.lang.Object
  extended by org.apache.cassandra.service.QuorumResponseHandler<T>
All Implemented Interfaces:
IAsyncCallback

public class QuorumResponseHandler<T>
extends java.lang.Object
implements IAsyncCallback


Constructor Summary
QuorumResponseHandler(int responseCount, IResponseResolver<T> responseResolver)
           
 
Method Summary
 void attachContext(java.lang.Object o)
          Attach some application specific context to the callback.
 T get()
           
 void response(Message message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

QuorumResponseHandler

public QuorumResponseHandler(int responseCount,
                             IResponseResolver<T> responseResolver)
                      throws org.apache.cassandra.service.InvalidRequestException
Throws:
org.apache.cassandra.service.InvalidRequestException
Method Detail

get

public T get()
      throws java.util.concurrent.TimeoutException,
             DigestMismatchException
Throws:
java.util.concurrent.TimeoutException
DigestMismatchException

response

public void response(Message message)
Specified by:
response in interface IAsyncCallback
Parameters:
message - responses to be returned

attachContext

public void attachContext(java.lang.Object o)
Description copied from interface: IAsyncCallback
Attach some application specific context to the callback.

Specified by:
attachContext in interface IAsyncCallback
Parameters:
o - application specific context


Copyright © 2009 The Apache Software Foundation