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}