org.springframework.web.socket.client.WebSocketConnectionManager.startInternal()方法的使用及代码示例

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

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

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;
    }
  });
}

相关文章