gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-27 09:03:05 29 4
gpt4 key购买 nike

本文整理了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;
    }
  });
}

29 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com