com.datastax.driver.stress
Class Consumer.Asynchronous

java.lang.Object
  java.lang.Thread
      com.datastax.driver.stress.Consumer
          com.datastax.driver.stress.Consumer.Asynchronous

All Implemented Interfaces:

Runnable

Enclosing class:

Consumer

public static class Consumer.Asynchronous
extends Consumer

Nested Class Summary

static class

Consumer.Asynchronous.ResultHandler

Nested classes/interfaces inherited from class com.datastax.driver.stress.Consumer

Consumer.Asynchronous

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class com.datastax.driver.stress.Consumer

reporter, session, workQueue

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Consumer.Asynchronous(Session session, BlockingQueue<QueryGenerator.Request> workQueue, Reporter reporter, Consumer.Asynchronous.ResultHandler resultHandler)

Method Summary

protected void	handle(QueryGenerator.Request request)
protected void	shutdown()

Methods inherited from class com.datastax.driver.stress.Consumer

run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Consumer.Asynchronous

public Consumer.Asynchronous(Session session,
                             BlockingQueue<QueryGenerator.Request> workQueue,
                             Reporter reporter,
                             Consumer.Asynchronous.ResultHandler resultHandler)

Method Detail

handle

protected void handle(QueryGenerator.Request request)
               throws NoHostAvailableException

Overrides:

handle in class Consumer

Throws:

NoHostAvailableException

shutdown

protected void shutdown()

Overrides:

shutdown in class Consumer