001package var.web.ws.sensor;
002
003import javax.websocket.OnClose;
004import javax.websocket.OnOpen;
005import javax.websocket.Session;
006import javax.websocket.server.ServerEndpoint;
007
008@ServerEndpoint(value = "/messungen")
009public class MessungsService {
010
011        @OnOpen
012        public void open(Session session) {
013                SensorSimulator sensor = new SensorSimulator(session);
014                session.getUserProperties().put("sensor", sensor);
015                sensor.start();
016        }
017
018        @SuppressWarnings("deprecation")
019        @OnClose
020        public void close(Session session) {
021                SensorSimulator sensor = (SensorSimulator) session.getUserProperties().get("sensor");
022                sensor.stop();
023                session.getUserProperties().remove("sensor");
024        }
025}