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

WebSocketConnectionManager.<init>介绍

暂无

代码示例

代码示例来源：origin: rampatra/jbot

/**
 * Entry point where the web socket connection starts
 * and after which your bot becomes live.
 */
@PostConstruct
protected void startRTMAndWebSocketConnection() {
  slackService.connectRTM(getSlackToken());
  if (slackService.getWebSocketUrl() != null) {
    webSocketManager = new WebSocketConnectionManager(client(), handler(), slackService.getWebSocketUrl());
    webSocketManager.start();
  } else {
    logger.error("No web socket url returned by Slack.");
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void openConnection() throws Exception {
  List<String> subprotocols = Arrays.asList("abc");
  TestLifecycleWebSocketClient client = new TestLifecycleWebSocketClient(false);
  WebSocketHandler handler = new TextWebSocketHandler();
  WebSocketConnectionManager manager = new WebSocketConnectionManager(client, handler , "/path/{id}", "123");
  manager.setSubProtocols(subprotocols);
  manager.openConnection();
  WebSocketHttpHeaders expectedHeaders = new WebSocketHttpHeaders();
  expectedHeaders.setSecWebSocketProtocol(subprotocols);
  assertEquals(expectedHeaders, client.headers);
  assertEquals(new URI("/path/123"), client.uri);
  WebSocketHandlerDecorator loggingHandler = (WebSocketHandlerDecorator) client.webSocketHandler;
  assertEquals(LoggingWebSocketHandlerDecorator.class, loggingHandler.getClass());
  assertSame(handler, loggingHandler.getDelegate());
}

代码示例来源：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: io.github.xinyang-pan.crypto4j/crypto4j-core

private WebSocketConnectionManager createConnectionManager(String url, S wsHandler) {
  StandardWebSocketClient client = new StandardWebSocketClient();
  return new WebSocketConnectionManager(client, wsHandler, url);
}

代码示例来源：origin: com.bosch.bis.monitoring/bis-event-publisher-impl

@Bean
public WebSocketConnectionManager webSocketConnectionManager(WebSocketClient wsClient, WebSocketHandler wsHandler) {
  WebSocketConnectionManager manager = new WebSocketConnectionManager(
      wsClient, wsHandler, serviceAddress.getUri().toString());
  manager.setAutoStartup(true);
  return manager;
}

代码示例来源：origin: io.github.qyvlik/jsonrpclite-core

public RpcClient(String wsUrl, int sendTimeLimit, int bufferSizeLimit) {
  this.sendTimeLimit = sendTimeLimit;
  this.bufferSizeLimit = bufferSizeLimit;
  this.wsUrl = wsUrl;
  WebSocketContainer container = ContainerProvider.getWebSocketContainer();
  container.setDefaultMaxTextMessageBufferSize(10 * 1024 * 1024);
  webSocketClient = new StandardWebSocketClient(container);
  webSocketConnectionManager = new WebSocketConnectionManager(webSocketClient,
      new RpcClientTextHandler(), this.wsUrl);
}