ctx) throws Exception {
@Override
public void cancel() {
- running = false;
+ isRunning = false;
}
@Override
@@ -143,4 +144,13 @@ public void close() throws Exception {
client.close();
}
+ /**
+ * {@inheritDoc}
+ *
+ * Sets the {@link #isRunning} flag to {@code false}.
+ */
+ @Override
+ public void stop() {
+ this.isRunning = false;
+ }
}