package websocket;

import javax.websocket.server.*;

import java.io.IOException;

import javax.websocket.*;

@ServerEndpoint("/hello/")
public class Server {
	private Session session;
	
	@OnOpen
	public void connect(Session session) {
		this.session= session;
		System.out.println("session :"+ session);
	}
	
	@OnClose 
	public void close() {
		this.session=null;
		System.out.println("session closed");
	}
	
	@OnMessage
	public void onMessage(String msg) throws IOException {
		System.out.println("msg recu:"+msg);
		this.session.getAsyncRemote().sendText("server:"+msg);
		//if (this.session != null && this.session.isOpen()) {
		//	this.session.getBasicRemote().sendText("server:"+msg);
		//}
	}

}