本文整理了Java中io.vertx.core.http.WebSocket.pause()
方法的一些代码示例,展示了WebSocket.pause()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebSocket.pause()
方法的具体详情如下:
包路径:io.vertx.core.http.WebSocket
类名称:WebSocket
方法名:pause
暂无
代码示例来源:origin: io.vertx/vertx-rx-java
public io.vertx.rxjava.core.http.WebSocket pause() {
delegate.pause();
return this;
}
代码示例来源:origin: vert-x3/vertx-rx
public io.vertx.rxjava.core.http.WebSocket pause() {
delegate.pause();
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();
}
内容来源于网络,如有侵权,请联系作者删除!