From c6cc8a87eb593dbf765814d1aaa09d5d231fa7fe Mon Sep 17 00:00:00 2001 From: Abyss777 Date: Thu, 26 May 2016 16:14:52 +0500 Subject: Events subsystem --- src/org/traccar/api/AsyncSocket.java | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'src/org/traccar/api/AsyncSocket.java') diff --git a/src/org/traccar/api/AsyncSocket.java b/src/org/traccar/api/AsyncSocket.java index 35e760613..2259f840f 100644 --- a/src/org/traccar/api/AsyncSocket.java +++ b/src/org/traccar/api/AsyncSocket.java @@ -20,6 +20,7 @@ import org.eclipse.jetty.websocket.api.WebSocketAdapter; import org.traccar.Context; import org.traccar.database.ConnectionManager; import org.traccar.model.Device; +import org.traccar.model.Event; import org.traccar.model.Position; import org.traccar.web.JsonConverter; @@ -32,6 +33,7 @@ public class AsyncSocket extends WebSocketAdapter implements ConnectionManager.U private static final String KEY_DEVICES = "devices"; private static final String KEY_POSITIONS = "positions"; + private static final String KEY_EVENTS = "events"; private long userId; @@ -65,6 +67,11 @@ public class AsyncSocket extends WebSocketAdapter implements ConnectionManager.U sendData(KEY_POSITIONS, Collections.singletonList(position)); } + @Override + public void onUpdateEvent(Event event) { + sendData(KEY_EVENTS, Collections.singletonList(event)); + } + private void sendData(String key, Collection data) { if (!data.isEmpty() && isConnected()) { JsonObjectBuilder json = Json.createObjectBuilder(); -- cgit v1.2.3