本文整理了Java中org.asynchttpclient.ws.WebSocket.isOpen()
方法的一些代码示例,展示了WebSocket.isOpen()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebSocket.isOpen()
方法的具体详情如下:
包路径:org.asynchttpclient.ws.WebSocket
类名称:WebSocket
方法名:isOpen
暂无
代码示例来源:origin: org.apache.camel/camel-ahc-ws
void reConnect() throws Exception {
if (websocket == null || !websocket.isOpen()) {
String uri = getHttpUri().toASCIIString();
LOG.info("Reconnecting websocket: {}", uri);
connect();
}
}
代码示例来源:origin: org.apache.camel/camel-ahc-ws
@Override
protected void doStop() throws Exception {
if (websocket != null && websocket.isOpen()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Disconnecting from {}", getHttpUri().toASCIIString());
}
websocket.removeWebSocketListener(listener);
websocket.sendCloseFrame();
websocket = null;
}
super.doStop();
}
代码示例来源:origin: allbegray/slack-api
public void close() {
logger.info("Slack RTM closing...");
stop = true;
if (webSocket != null && webSocket.isOpen()) {
webSocket.sendCloseFrame();
}
if (asyncHttpClient != null && !asyncHttpClient.isClosed()) {
try {
asyncHttpClient.close();
} catch (IOException e) {
// ignore
}
}
logger.info("Slack RTM closed.");
}
内容来源于网络,如有侵权,请联系作者删除!