Skip to content

Instantly share code, notes, and snippets.

@krishnabhargav
Created November 12, 2014 13:43
Show Gist options
  • Save krishnabhargav/e0965b0e1ebb5c8067ec to your computer and use it in GitHub Desktop.
Save krishnabhargav/e0965b0e1ebb5c8067ec to your computer and use it in GitHub Desktop.
Websocket server inside a scala application
import org.atmosphere.config.service.WebSocketHandlerService
import org.atmosphere.nettosphere.{Config, Nettosphere}
import org.atmosphere.websocket.{WebSocket, WebSocketHandlerAdapter}
object Main {
def main(args: Array[String]) {
val builder = new Config.Builder().host("127.0.0.1").port(8080)
val server = new Nettosphere.Builder().config(builder.build()).build()
server.start()
System.in.read()
}
@WebSocketHandlerService(path = "/echo")
class WebSocketChat extends WebSocketHandlerAdapter {
override def onOpen(webSocket: WebSocket) {
System.out.println("Connection received")
}
override def onTextMessage(webSocket: WebSocket, message: String) {
System.out.println("Received message")
webSocket.write(message)
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment