aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/traccar/api
diff options
context:
space:
mode:
authorAnton Tananaev <anton@traccar.org>2022-06-25 14:17:00 -0700
committerAnton Tananaev <anton@traccar.org>2022-06-25 14:17:00 -0700
commit2fcffc5b55f59310d289a21d1ebc2ee6bf15bcd5 (patch)
tree89b881064fbd3ed3d258c183273a6d23ebd56a0f /src/main/java/org/traccar/api
parentc53d98c668af9c79767e22964f05c7bf7dc866f2 (diff)
downloadtrackermap-server-2fcffc5b55f59310d289a21d1ebc2ee6bf15bcd5.tar.gz
trackermap-server-2fcffc5b55f59310d289a21d1ebc2ee6bf15bcd5.tar.bz2
trackermap-server-2fcffc5b55f59310d289a21d1ebc2ee6bf15bcd5.zip
Fix connection users issue
Diffstat (limited to 'src/main/java/org/traccar/api')
-rw-r--r--src/main/java/org/traccar/api/AsyncSocket.java7
-rw-r--r--src/main/java/org/traccar/api/resource/DeviceResource.java4
2 files changed, 5 insertions, 6 deletions
diff --git a/src/main/java/org/traccar/api/AsyncSocket.java b/src/main/java/org/traccar/api/AsyncSocket.java
index 40aa68e88..5fc4b4412 100644
--- a/src/main/java/org/traccar/api/AsyncSocket.java
+++ b/src/main/java/org/traccar/api/AsyncSocket.java
@@ -58,15 +58,14 @@ public class AsyncSocket extends WebSocketAdapter implements ConnectionManager.U
public void onWebSocketConnect(Session session) {
super.onWebSocketConnect(session);
- Map<String, Collection<?>> data = new HashMap<>();
try {
+ Map<String, Collection<?>> data = new HashMap<>();
data.put(KEY_POSITIONS, PositionUtil.getLatestPositions(storage, userId));
+ sendData(data);
+ connectionManager.addListener(userId, this);
} catch (StorageException e) {
throw new RuntimeException(e);
}
- sendData(data);
-
- connectionManager.addListener(userId, this);
}
@Override
diff --git a/src/main/java/org/traccar/api/resource/DeviceResource.java b/src/main/java/org/traccar/api/resource/DeviceResource.java
index 2b673a108..e205f2d28 100644
--- a/src/main/java/org/traccar/api/resource/DeviceResource.java
+++ b/src/main/java/org/traccar/api/resource/DeviceResource.java
@@ -137,8 +137,8 @@ public class DeviceResource extends BaseObjectResource<Device> {
try {
cacheManager.addDevice(position.getDeviceId());
cacheManager.updatePosition(position);
- connectionManager.updatePosition(position);
- broadcastService.updatePosition(position);
+ connectionManager.updatePosition(true, position);
+ broadcastService.updatePosition(true, position);
} finally {
cacheManager.removeDevice(position.getDeviceId());
}