@ThreadSafe public class BasicRequestCycle<M> extends java.lang.Object implements RequestCycle<M>, java.lang.Runnable
Constructor and Description |
---|
BasicRequestCycle(DriverDiagnosticsImpl diagnosticsContext,
java.util.concurrent.ScheduledExecutorService executor,
RequestHealth requestHealth,
java.lang.String metricContext,
com.codahale.metrics.MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
com.codahale.metrics.Timer |
getAggregateTimer() |
void |
messageArrived(M message,
java.lang.Object key) |
void |
postRequest(Request<M> request,
long delay) |
void |
run() |
void |
setConcurrency(int concurrency) |
void |
shutdown(boolean driverShutdown)
Shutdown the request cycle.
|
void |
startup() |
public BasicRequestCycle(DriverDiagnosticsImpl diagnosticsContext, java.util.concurrent.ScheduledExecutorService executor, RequestHealth requestHealth, java.lang.String metricContext, com.codahale.metrics.MetricRegistry metricRegistry)
public void startup()
startup
in interface RequestCycle<M>
public void postRequest(Request<M> request, long delay)
postRequest
in interface RequestCycle<M>
public void run()
run
in interface java.lang.Runnable
public void messageArrived(M message, java.lang.Object key)
messageArrived
in interface RequestCycle<M>
public void shutdown(boolean driverShutdown)
RequestCycle
shutdown
in interface RequestCycle<M>
driverShutdown
- When true
, Request.fail(FailureType, DriverState, Exception)
won't be called during
shutdown.public void setConcurrency(int concurrency)
setConcurrency
in interface RequestCycle<M>
public com.codahale.metrics.Timer getAggregateTimer()