thoerup/websocket/AnnotatedSocket.java

package dk.thoerup.websocket;

import java.io.IOException;
import java.util.HashMap;

import javax.websocket.CloseReason;
import javax.websocket.EndpointConfig;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;


@ServerEndpoint("/wstest")
public class AnnotatedSocket {
        static private HashMap<String, Session> sessions = new HashMap<String,Session>();
        
        
        @OnOpen
        public void open(Session session, EndpointConfig conf) {
                sessions.put(session.getId(), session);         
        }
        
        @OnError
        public void error(Session session, Throwable error) {           
        }
        
        @OnClose
        public void close(Session session, CloseReason reason) {
                sessions.remove(session.getId());
        }
        

        @OnMessage
        public void onMessage(Session session, String msg) {
                try {
                        for(Session ses: sessions.values() ) {
                                ses.getBasicRemote().sendText( session.getId() + " > " + msg);                          
                        }
                        System.out.println("Returned msg: " + msg);
                } catch (IOException e) {
                        System.out.println("Error returning message " + e.getMessage() );
                }
        }
}
1	package dk.thoerup.websocket;
2
3	import java.io.IOException;
4	import java.util.HashMap;
5
6	import javax.websocket.CloseReason;
7	import javax.websocket.EndpointConfig;
8	import javax.websocket.OnClose;
9	import javax.websocket.OnError;
10	import javax.websocket.OnMessage;
11	import javax.websocket.OnOpen;
12	import javax.websocket.Session;
13	import javax.websocket.server.ServerEndpoint;
14
15
16	@ServerEndpoint("/wstest")
17	public class AnnotatedSocket {
18	static private HashMap<String, Session> sessions = new HashMap<String,Session>();
19
20
21	@OnOpen
22	public void open(Session session, EndpointConfig conf) {
23	sessions.put(session.getId(), session);
24	}
25
26	@OnError
27	public void error(Session session, Throwable error) {
28	}
29
30	@OnClose
31	public void close(Session session, CloseReason reason) {
32	sessions.remove(session.getId());
33	}
34
35
36	@OnMessage
37	public void onMessage(Session session, String msg) {
38	try {
39	for(Session ses: sessions.values() ) {
40	ses.getBasicRemote().sendText( session.getId() + " > " + msg);
41	}
42	System.out.println("Returned msg: " + msg);
43	} catch (IOException e) {
44	System.out.println("Error returning message " + e.getMessage() );
45	}
46	}
47	}