package com.its


import org.eclipse.jetty.websocket.client.ClientUpgradeRequest;
import org.eclipse.jetty.websocket.client.WebSocketClient;
import org.springframework.boot.autoconfigure.SpringBootApplication
import java.net.URI
import java.util.concurrent.TimeUnit







    fun main(args: Array<String>)
    {
        start()
    }

private fun  start()
{
    var destUri = "ws://127.0.0.1:8765"
    var client = WebSocketClient()
    var socket = SimpleEchoSocket()
    try {
        client.start()
        var echoUri = URI(destUri)
        var request = ClientUpgradeRequest()

        System.out.printf("Connecting to : %s%n", echoUri)


        var fut=client.connect(socket, echoUri, request)
        val session=fut.get()
        session!!.remote.sendString("Hay!")


        // wait for closed socket connection.
        socket.awaitClose(5, TimeUnit.SECONDS)
    } catch (t: Throwable) {
        t.printStackTrace()
    }

}