本文整理了Java中org.springframework.web.socket.client.WebSocketConnectionManager.startInternal()
方法的一些代码示例,展示了WebSocketConnectionManager.startInternal()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebSocketConnectionManager.startInternal()
方法的具体详情如下:
包路径:org.springframework.web.socket.client.WebSocketConnectionManager
类名称:WebSocketConnectionManager
方法名:startInternal
暂无
代码示例来源:origin: spring-projects/spring-framework
@Test
public void clientLifecycle() throws Exception {
TestLifecycleWebSocketClient client = new TestLifecycleWebSocketClient(false);
WebSocketHandler handler = new TextWebSocketHandler();
WebSocketConnectionManager manager = new WebSocketConnectionManager(client, handler , "/a");
manager.startInternal();
assertTrue(client.isRunning());
manager.stopInternal();
assertFalse(client.isRunning());
}
代码示例来源:origin: com.bosch.bis.monitoring/bis-event-publisher-impl
void sendMessage(byte[] message) {
BinaryMessage binaryMessage = new BinaryMessage(message);
webSocketRetryExecutor.doWithRetry(retryContext -> {
if (serverSession == null) {
throw new ConnectionNotEstablishedYetException();
}
if (!serverSession.isOpen()) {
LOG.warn("Connection has been closed meanwhile, reconnecting...");
tokenRetriever.updateOAuth2AuthenticationHeader();
manager.startInternal();
throw new ConnectionNotEstablishedYetException();
}
try {
serverSession.sendMessage(binaryMessage);
} catch (IOException e) {
LOG.error("Failed to send websocket message (attempt " + retryContext.getRetryCount()
+ " with error: " + e.getMessage(), e);
throw e;
}
});
}
内容来源于网络,如有侵权,请联系作者删除!