Annotated Websocket Endpoint

MyWsendpoint.java

//imports ommitted

@ServerEndpoint("/testwsep")
public class MyWsendpoint {

    static Set<Session> clients = new HashSet<Session>();

    @OnOpen
    public void open(Session s) {
        clients.add(s);
    }

    @OnMessage
    public void msg(String m) {
        for (Session client : clients) {
            try {
                client.getBasicRemote().sendText("Catch this! "+ m);
            } catch (IOException ex) {
                Logger.getLogger(MyWsendpoint.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }
//.. other callback methods ommitted - @onClose, @onError
}