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

WebSocketStompClient.<init>介绍

[英]Class constructor. Sets #setDefaultHeartbeat to "0,0" but will reset it back to the preferred "10000,10000" when a #setTaskScheduler is configured.
[中]类构造函数。将#setDefaultHeartbeat设置为“0,0”，但在配置#setTaskScheduler时将其重置为首选的“1000010000”。

代码示例

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

@Test
public void heartbeatDefaultValueSetWithoutScheduler() throws Exception {
  WebSocketStompClient stompClient = new WebSocketStompClient(mock(WebSocketClient.class));
  stompClient.setDefaultHeartbeat(new long[] {5, 5});
  try {
    stompClient.processConnectHeaders(null);
    fail("Expected IllegalStateException");
  }
  catch (IllegalStateException ex) {
    // ignore
  }
}

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

@Test
public void heartbeatDefaultValueWithScheduler() throws Exception {
  WebSocketStompClient stompClient = new WebSocketStompClient(mock(WebSocketClient.class));
  stompClient.setTaskScheduler(mock(TaskScheduler.class));
  assertArrayEquals(new long[] {10000, 10000}, stompClient.getDefaultHeartbeat());
  StompHeaders connectHeaders = stompClient.processConnectHeaders(null);
  assertArrayEquals(new long[] {10000, 10000}, connectHeaders.getHeartbeat());
}

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

@Test
public void heartbeatDefaultValue() throws Exception {
  WebSocketStompClient stompClient = new WebSocketStompClient(mock(WebSocketClient.class));
  assertArrayEquals(new long[] {0, 0}, stompClient.getDefaultHeartbeat());
  StompHeaders connectHeaders = stompClient.processConnectHeaders(null);
  assertArrayEquals(new long[] {0, 0}, connectHeaders.getHeartbeat());
}

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

@Before
public void setUp() throws Exception {
  logger.debug("Setting up before '" + this.testName.getMethodName() + "'");
  this.wac = new AnnotationConfigWebApplicationContext();
  this.wac.register(TestConfig.class);
  this.wac.refresh();
  this.server = new TomcatWebSocketTestServer();
  this.server.setup();
  this.server.deployConfig(this.wac);
  this.server.start();
  WebSocketClient webSocketClient = new StandardWebSocketClient();
  this.stompClient = new WebSocketStompClient(webSocketClient);
  this.stompClient.setMessageConverter(new StringMessageConverter());
}

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

@Bean
public WebSocketStompClient stompClient(TaskScheduler taskScheduler) {
  WebSocketStompClient webSocketStompClient = new WebSocketStompClient(webSocketClient());
  webSocketStompClient.setMessageConverter(new MappingJackson2MessageConverter());
  webSocketStompClient.setTaskScheduler(taskScheduler);
  return webSocketStompClient;
}

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

@Bean
public WebSocketStompClient stompClient(TaskScheduler taskScheduler) {
  WebSocketStompClient webSocketStompClient = new WebSocketStompClient(webSocketClient());
  webSocketStompClient.setTaskScheduler(taskScheduler);
  webSocketStompClient.setReceiptTimeLimit(5000);
  webSocketStompClient.setMessageConverter(new StringMessageConverter());
  return webSocketStompClient;
}

代码示例来源：origin: mthizo247/spring-cloud-netflix-zuul-websocket

@Bean
@ConditionalOnMissingBean(WebSocketStompClient.class)
public WebSocketStompClient stompClient(WebSocketClient webSocketClient, MessageConverter messageConverter,
                    @Qualifier("proxyStompClientTaskScheduler") TaskScheduler taskScheduler) {
  int bufferSizeLimit = 1024 * 1024 * 8;
  WebSocketStompClient client = new WebSocketStompClient(webSocketClient);
  client.setInboundMessageSizeLimit(bufferSizeLimit);
  client.setMessageConverter(messageConverter);
  client.setTaskScheduler(taskScheduler);
  client.setDefaultHeartbeat(new long[]{0, 0});
  return client;
}

代码示例来源：origin: CaledoniaProject/CVE-2018-1270

public static void main(String... argv) {
    WebSocketClient webSocketClient = new StandardWebSocketClient();
    WebSocketStompClient stompClient = new WebSocketStompClient(webSocketClient);
    stompClient.setMessageConverter(new MappingJackson2MessageConverter());
    stompClient.setTaskScheduler(new ConcurrentTaskScheduler());

    String url = "ws://127.0.0.1:8080/hello";
    StompSessionHandler sessionHandler = new MySessionHandler();
    stompClient.connect(url, sessionHandler);

    new Scanner(System.in).nextLine(); //Don't close immediately.
  }
}