aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/traccar/database/ConnectionManager.java
diff options
context:
space:
mode:
authorkamaci <furkankamaci@gmail.com>2020-10-19 00:01:12 +0300
committerkamaci <furkankamaci@gmail.com>2020-10-19 00:01:12 +0300
commit3cd7831692b1725713e297372a0181e5ae614eb9 (patch)
tree46725cd3575e53ff9ff40b44236b34a323f804ac /src/main/java/org/traccar/database/ConnectionManager.java
parent98c2e3da5ea0670360078a3f278ddef7d9e39953 (diff)
downloadtraccar-server-3cd7831692b1725713e297372a0181e5ae614eb9.tar.gz
traccar-server-3cd7831692b1725713e297372a0181e5ae614eb9.tar.bz2
traccar-server-3cd7831692b1725713e297372a0181e5ae614eb9.zip
Anonymous types are replaced with lambda.
Diffstat (limited to 'src/main/java/org/traccar/database/ConnectionManager.java')
-rw-r--r--src/main/java/org/traccar/database/ConnectionManager.java10
1 files changed, 3 insertions, 7 deletions
diff --git a/src/main/java/org/traccar/database/ConnectionManager.java b/src/main/java/org/traccar/database/ConnectionManager.java
index 4d43bc71b..9342fd3de 100644
--- a/src/main/java/org/traccar/database/ConnectionManager.java
+++ b/src/main/java/org/traccar/database/ConnectionManager.java
@@ -17,7 +17,6 @@ package org.traccar.database;
import io.netty.channel.Channel;
import io.netty.util.Timeout;
-import io.netty.util.TimerTask;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.traccar.Context;
@@ -122,12 +121,9 @@ public class ConnectionManager {
}
if (status.equals(Device.STATUS_ONLINE)) {
- timeouts.put(deviceId, GlobalTimer.getTimer().newTimeout(new TimerTask() {
- @Override
- public void run(Timeout timeout) {
- if (!timeout.isCancelled()) {
- updateDevice(deviceId, Device.STATUS_UNKNOWN, null);
- }
+ timeouts.put(deviceId, GlobalTimer.getTimer().newTimeout(timeout1 -> {
+ if (!timeout1.isCancelled()) {
+ updateDevice(deviceId, Device.STATUS_UNKNOWN, null);
}
}, deviceTimeout, TimeUnit.MILLISECONDS));
}