import java.io.IOException;

import java.util.logging.Level;

import java.util.logging.Logger;

import javax.websocket.ClientEndpoint;

import javax.websocket.OnError;

import javax.websocket.OnMessage;

import javax.websocket.OnOpen;

import javax.websocket.Session;

@ClientEndpoint

public class MyClientEndpoint {

@OnOpen

public void onOpen(Session session) {

System.out.println("Connected to endpoint: " + session.getBasicRemote());

try {

// String name = "ozzyk";

String name = " GET / HTTP/1.0\\r\\n\\r\\n";

System.out.println("Sending message to endpoint: " + name);

session.getBasicRemote().sendText(name);

} catch (IOException ex) {

Logger.getLogger(MyClientEndpoint.class.getName()).log(Level.SEVERE, null, ex);

}

}

@OnMessage

public void processMessage(String message) {

System.out.println("Received message in client: " + message);

Client.messageLatch.countDown();

}

@OnError

public void processError(Throwable t) {

t.printStackTrace();

}

}