Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import org.vertx.java.core.Handler;
- import org.vertx.java.core.buffer.Buffer;
- import org.vertx.java.core.http.HttpServer;
- import org.vertx.java.core.http.ServerWebSocket;
- import org.vertx.java.platform.Verticle;
- public class ClientCommunicationVerticle extends Verticle {
- private HttpServer httpServer = null;
- public void start() {
- httpServer = vertx.createHttpServer()
- .websocketHandler(new ServerWebsocketHandler()).listen(9090);
- }
- class ServerWebsocketHandler implements Handler<ServerWebSocket> {
- public void handle(final ServerWebSocket ws) {
- ws.dataHandler(new Handler<Buffer>() {
- public void handle(Buffer data) {
- container.logger().info("--->" + data.toString() + "<---");
- }
- });
- }
- }
- public void close() {
- if (httpServer != null)
- httpServer.close();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement