@Override
public Future<RpcResult<Void>> stressTest(StressTestInput input) {
- final int inputRate, inputCount;
+ final int inputRate;
+ final long inputCount;
// If rate is not provided, or given as zero, then just return.
if ((input.getRate() == null) || (input.getRate() == 0)) {