package com.cloudera.flume.faults;
long delay;
boolean random;
this.delay = delay;
this.random = true;
}
try {
while (true) {
long wait = (long) (delay * (random ? Math.random() : 1.0));
Thread.sleep(wait);
increment();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
new Thread(this.getClass().getName()) {
exhaust();
}
}.start();
}
}