| Constructor and Description |
|---|
BenchmarkCallback(BenchmarkUtils.ThroughputLatencyAggregator agg) |
| Modifier and Type | Method and Description |
|---|---|
void |
operationFailed(Object ctx,
PubSubException exception)
This method is called when the operation failed due to some reason.
|
void |
operationFinished(Object ctx,
Void resultOfOperation)
This method is called when the asynchronous operation finishes
|
public BenchmarkCallback(BenchmarkUtils.ThroughputLatencyAggregator agg) throws InterruptedException
InterruptedExceptionpublic void operationFinished(Object ctx, Void resultOfOperation)
CallbackoperationFinished in interface Callback<Void>public void operationFailed(Object ctx, PubSubException exception)
CallbackoperationFailed in interface Callback<Void>ctx - The context for the callbackexception - The reason for the failure of the scanCopyright © 2011–2021 The Apache Software Foundation. All rights reserved.