aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/apache/commons/io/input/Tailer.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/apache/commons/io/input/Tailer.java')
-rw-r--r--src/main/java/org/apache/commons/io/input/Tailer.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/main/java/org/apache/commons/io/input/Tailer.java b/src/main/java/org/apache/commons/io/input/Tailer.java
index 6e067c80..7212b692 100644
--- a/src/main/java/org/apache/commons/io/input/Tailer.java
+++ b/src/main/java/org/apache/commons/io/input/Tailer.java
@@ -36,6 +36,7 @@ import java.util.Arrays;
import java.util.Objects;
import org.apache.commons.io.IOUtils;
+import org.apache.commons.io.ThreadUtils;
import org.apache.commons.io.file.PathUtils;
import org.apache.commons.io.file.attribute.FileTimes;
@@ -899,7 +900,7 @@ public class Tailer implements Runnable, AutoCloseable {
listener.fileNotFound();
}
if (reader == null) {
- Thread.sleep(delayDuration.toMillis());
+ ThreadUtils.sleep(delayDuration);
} else {
// The current position in the file
position = tailAtEnd ? tailable.size() : 0;
@@ -929,7 +930,7 @@ public class Tailer implements Runnable, AutoCloseable {
} catch (final FileNotFoundException e) {
// in this case we continue to use the previous reader and position values
listener.fileNotFound();
- Thread.sleep(delayDuration.toMillis());
+ ThreadUtils.sleep(delayDuration);
}
continue;
}
@@ -954,7 +955,7 @@ public class Tailer implements Runnable, AutoCloseable {
if (reOpen && reader != null) {
reader.close();
}
- Thread.sleep(delayDuration.toMillis());
+ ThreadUtils.sleep(delayDuration);
if (getRun() && reOpen) {
reader = tailable.getRandomAccess(RAF_READ_ONLY_MODE);
reader.seek(position);