Package org.vertx.java.core.http.impl.ws

Examples of org.vertx.java.core.http.impl.ws.WebSocketFrame

89
90
91
92
93
94
95
96
    if (data.isWrapper()) {
      // call retain to make sure it is not released before the write completes
      // the write will call buf.release() by it own
      buf.retain();
    }
    WebSocketFrame frame = new DefaultWebSocketFrame(WebSocketFrame.FrameType.BINARY, buf);
    writeFrame(frame);
  }
View Full Code Here
94
95
96
97
98
99
100
101
    WebSocketFrame frame = new DefaultWebSocketFrame(WebSocketFrame.FrameType.BINARY, buf);
    writeFrame(frame);
  }

  protected void writeTextFrameInternal(String str) {
    WebSocketFrame frame = new DefaultWebSocketFrame(str);
    writeFrame(frame);
  }
View Full Code Here
612
613
614
615
616
617
618
619
620
621
622
623
            conn.handleMessage(msg);
          }
        }
      } else if (msg instanceof WebSocketFrame) {
        //Websocket frame
        WebSocketFrame wsFrame = (WebSocketFrame)msg;
        switch (wsFrame.getType()) {
          case BINARY:
          case TEXT:
            if (conn != null) {
              conn.handleMessage(msg);
            }
View Full Code Here
610
611
612
613
614
615
616
617
618
619
620
        if (chunk instanceof LastHttpContent) {
          conn.handleResponseEnd((LastHttpContent)chunk);
        }
        valid = true;
      } else if (msg instanceof WebSocketFrame) {
        WebSocketFrame frame = (WebSocketFrame) msg;
        conn.handleWsFrame(frame);
        valid = true;
      }
      if (!valid) {
        throw new IllegalStateException("Invalid object " + msg);
View Full Code Here
295
296
297
298
299
300
301
302
303
304
305
          // Requeue
          pending.add(LastHttpContent.EMPTY_LAST_CONTENT);
        }
      }
    } else if (msg instanceof WebSocketFrame) {
      WebSocketFrame frame = (WebSocketFrame) msg;
      handleWsFrame(frame);
    }

    checkNextTick();
  }
View Full Code Here
TOP

Related Classes of org.vertx.java.core.http.impl.ws.WebSocketFrame

  • org.vertx.java.core.http.impl.DefaultHttpClient$ClientHandler
  • org.vertx.java.core.http.impl.DefaultHttpServer$ServerHandler
  • org.vertx.java.core.http.impl.ServerConnection
  • org.vertx.java.core.http.impl.WebSocketImplBase
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.