io.vertx.core.http.WebSocket.resume()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(1.5k)|赞(0)|评价(0)|浏览(140)

本文整理了Java中io.vertx.core.http.WebSocket.resume()方法的一些代码示例,展示了WebSocket.resume()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebSocket.resume()方法的具体详情如下:
包路径:io.vertx.core.http.WebSocket
类名称:WebSocket
方法名:resume

WebSocket.resume介绍

暂无

代码示例

代码示例来源:origin: io.vertx/vertx-rx-java

public io.vertx.rxjava.core.http.WebSocket resume() { 
 delegate.resume();
 return this;
}

代码示例来源:origin: vert-x3/vertx-rx

public io.vertx.rxjava.core.http.WebSocket resume() { 
 delegate.resume();
 return this;
}

代码示例来源:origin: GruppoFilippetti/vertx-mqtt-broker

@Override
public void handle(WebSocket webSocket) {
  connecting = false;
  connected = true;
  logger.info("Bridge Client - connected to server [" + remoteBridgeHost + ":" + remoteBridgePort + "]");
  webSocket.write(Buffer.buffer( tenant + "\n" ));
  webSocket.write(Buffer.buffer( "START SESSION" + "\n" ));
  webSocket.pause();
  final EventBusWebsocketBridge ebnb = new EventBusWebsocketBridge(webSocket, vertx.eventBus(), address);
  webSocket.closeHandler(aVoid -> {
    logger.error("Bridge Client - closed connection from server [" + remoteBridgeHost + ":" + remoteBridgePort + "]" + webSocket.textHandlerID());
    ebnb.stop();
    connected = false;
  });
  webSocket.exceptionHandler(throwable -> {
    logger.error("Bridge Client - Exception: " + throwable.getMessage(), throwable);
    ebnb.stop();
    connected = false;
  });
  ebnb.setTenant(tenant);
  ebnb.start();
  logger.info("Bridge Client - bridgeUUID: "+ ebnb.getBridgeUUID());
  webSocket.resume();
}

相关文章