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

WebSocketStompClient.getTaskScheduler介绍

暂无

代码示例

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

@Override
public void onReadInactivity(final Runnable runnable, final long duration) {
  Assert.state(getTaskScheduler() != null, "No TaskScheduler configured");
  this.lastReadTime = System.currentTimeMillis();
  this.inactivityTasks.add(getTaskScheduler().scheduleWithFixedDelay(() -> {
    if (System.currentTimeMillis() - this.lastReadTime > duration) {
      try {
        runnable.run();
      }
      catch (Throwable ex) {
        if (logger.isDebugEnabled()) {
          logger.debug("ReadInactivityTask failure", ex);
        }
      }
    }
  }, duration / 2));
}

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

@Override
public void onWriteInactivity(final Runnable runnable, final long duration) {
  Assert.state(getTaskScheduler() != null, "No TaskScheduler configured");
  this.lastWriteTime = System.currentTimeMillis();
  this.inactivityTasks.add(getTaskScheduler().scheduleWithFixedDelay(() -> {
    if (System.currentTimeMillis() - this.lastWriteTime > duration) {
      try {
        runnable.run();
      }
      catch (Throwable ex) {
        if (logger.isDebugEnabled()) {
          logger.debug("WriteInactivityTask failure", ex);
        }
      }
    }
  }, duration / 2));
}

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

@Override
protected StompHeaders processConnectHeaders(@Nullable StompHeaders connectHeaders) {
  connectHeaders = super.processConnectHeaders(connectHeaders);
  if (connectHeaders.isHeartbeatEnabled()) {
    Assert.state(getTaskScheduler() != null, "TaskScheduler must be set if heartbeats are enabled");
  }
  return connectHeaders;
}

代码示例来源：origin: org.springframework/spring-websocket

@Override
public void onWriteInactivity(final Runnable runnable, final long duration) {
  Assert.state(getTaskScheduler() != null, "No TaskScheduler configured");
  this.lastWriteTime = System.currentTimeMillis();
  this.inactivityTasks.add(getTaskScheduler().scheduleWithFixedDelay(() -> {
    if (System.currentTimeMillis() - this.lastWriteTime > duration) {
      try {
        runnable.run();
      }
      catch (Throwable ex) {
        if (logger.isDebugEnabled()) {
          logger.debug("WriteInactivityTask failure", ex);
        }
      }
    }
  }, duration / 2));
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void onWriteInactivity(final Runnable runnable, final long duration) {
  Assert.state(getTaskScheduler() != null, "No TaskScheduler configured");
  this.lastWriteTime = System.currentTimeMillis();
  this.inactivityTasks.add(getTaskScheduler().scheduleWithFixedDelay(() -> {
    if (System.currentTimeMillis() - this.lastWriteTime > duration) {
      try {
        runnable.run();
      }
      catch (Throwable ex) {
        if (logger.isDebugEnabled()) {
          logger.debug("WriteInactivityTask failure", ex);
        }
      }
    }
  }, duration / 2));
}

代码示例来源：origin: org.springframework/spring-websocket

@Override
public void onReadInactivity(final Runnable runnable, final long duration) {
  Assert.state(getTaskScheduler() != null, "No TaskScheduler configured");
  this.lastReadTime = System.currentTimeMillis();
  this.inactivityTasks.add(getTaskScheduler().scheduleWithFixedDelay(() -> {
    if (System.currentTimeMillis() - this.lastReadTime > duration) {
      try {
        runnable.run();
      }
      catch (Throwable ex) {
        if (logger.isDebugEnabled()) {
          logger.debug("ReadInactivityTask failure", ex);
        }
      }
    }
  }, duration / 2));
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void onReadInactivity(final Runnable runnable, final long duration) {
  Assert.state(getTaskScheduler() != null, "No TaskScheduler configured");
  this.lastReadTime = System.currentTimeMillis();
  this.inactivityTasks.add(getTaskScheduler().scheduleWithFixedDelay(() -> {
    if (System.currentTimeMillis() - this.lastReadTime > duration) {
      try {
        runnable.run();
      }
      catch (Throwable ex) {
        if (logger.isDebugEnabled()) {
          logger.debug("ReadInactivityTask failure", ex);
        }
      }
    }
  }, duration / 2));
}

代码示例来源：origin: org.springframework/spring-websocket

@Override
protected StompHeaders processConnectHeaders(@Nullable StompHeaders connectHeaders) {
  connectHeaders = super.processConnectHeaders(connectHeaders);
  if (connectHeaders.isHeartbeatEnabled()) {
    Assert.state(getTaskScheduler() != null, "TaskScheduler must be set if heartbeats are enabled");
  }
  return connectHeaders;
}

代码示例来源：origin: apache/servicemix-bundles

@Override
protected StompHeaders processConnectHeaders(@Nullable StompHeaders connectHeaders) {
  connectHeaders = super.processConnectHeaders(connectHeaders);
  if (connectHeaders.isHeartbeatEnabled()) {
    Assert.state(getTaskScheduler() != null, "TaskScheduler must be set if heartbeats are enabled");
  }
  return connectHeaders;
}