com.ning.http.client.AsyncHttpClientConfig.getWebSocketTimeout()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(4.0k)|赞(0)|评价(0)|浏览(93)

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

AsyncHttpClientConfig.getWebSocketTimeout介绍

[英]Return the maximum time, in milliseconds, a com.ning.http.client.ws.WebSocket may be idle before being timed out.
[中]返回com的最大时间(以毫秒为单位)。宁。http。客户ws。WebSocket在超时之前可能处于空闲状态。

代码示例

代码示例来源:origin: com.ning/async-http-client

@Override
  public long getTimeout(final FilterChainContext ctx) {
    final Connection connection = ctx.getConnection();
    
    if (connectionManager.isReadyInPool(connection)) {
      // if the connection is in pool - let ConnectionManager take care of its life cycle
      return IdleTimeoutFilter.FOREVER;
    }
    
    final HttpTransactionContext context
        = HttpTransactionContext.currentTransaction(connection);
    if (context != null) {
      if (context.isWSRequest) {
        return clientConfig.getWebSocketTimeout();
      }
      final long timeout = context.getAhcRequest().getRequestTimeout();
      if (timeout > 0) {
        return timeout;
      }
    }
    return timeout;
  }
};

代码示例来源:origin: io.gatling/async-http-client

@Override
  public long getTimeout(FilterChainContext ctx) {
    final HttpTransactionContext context =
        HttpTransactionContext.get(ctx.getConnection());
    if (context != null) {
      if (context.isWSRequest) {
        return clientConfig.getWebSocketTimeout();
      }
      final long timeout = context.request.getRequestTimeout();
      if (timeout > 0) {
        return timeout;
      }
    }
    return timeout;
  }
};

代码示例来源:origin: com.ning/async-http-client

WebSocketHolder.set(ctx.getConnection(), context.protocolHandler, ws);
((WebSocketUpgradeHandler) context.getAsyncHandler()).onSuccess(context.webSocket);
final int wsTimeout = provider.getClientConfig().getWebSocketTimeout();
IdleTimeoutFilter.setCustomTimeout(ctx.getConnection(),
    (wsTimeout <= 0) ? IdleTimeoutFilter.FOREVER : wsTimeout,

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-client

@Override
  public long getTimeout(final FilterChainContext ctx) {
    final Connection connection = ctx.getConnection();
    
    if (connectionManager.isReadyInPool(connection)) {
      // if the connection is in pool - let ConnectionManager take care of its life cycle
      return IdleTimeoutFilter.FOREVER;
    }
    
    final HttpTransactionContext context
        = HttpTransactionContext.currentTransaction(connection);
    if (context != null) {
      if (context.isWSRequest) {
        return clientConfig.getWebSocketTimeout();
      }
      final long timeout = context.getAhcRequest().getRequestTimeout();
      if (timeout > 0) {
        return timeout;
      }
    }
    return timeout;
  }
};

代码示例来源:origin: javaee/grizzly-ahc

@Override
  public long getTimeout(final FilterChainContext ctx) {
    final Connection connection = ctx.getConnection();
    
    if (connectionManager.isReadyInPool(connection)) {
      // if the connection is in pool - let ConnectionManager take care of its life cycle
      return IdleTimeoutFilter.FOREVER;
    }
    
    final HttpTransactionContext context
        = HttpTransactionContext.currentTransaction(connection);
    if (context != null) {
      if (context.isWSRequest) {
        return clientConfig.getWebSocketTimeout();
      }
      final long timeout = context.getAhcRequest().getRequestTimeout();
      if (timeout > 0) {
        return timeout;
      }
    }
    return timeout;
  }
};

代码示例来源:origin: io.gatling/async-http-client

ws);
((WebSocketUpgradeHandler) context.handler).onSuccess(context.webSocket);
final int wsTimeout = context.provider.clientConfig.getWebSocketTimeout();
IdleTimeoutFilter.setCustomTimeout(ctx.getConnection(),
    ((wsTimeout <= 0)

代码示例来源:origin: javaee/grizzly-ahc

WebSocketHolder.set(ctx.getConnection(), context.protocolHandler, ws);
((WebSocketUpgradeHandler) context.getAsyncHandler()).onSuccess(context.webSocket);
final int wsTimeout = provider.getClientConfig().getWebSocketTimeout();
IdleTimeoutFilter.setCustomTimeout(ctx.getConnection(),
    (wsTimeout <= 0) ? IdleTimeoutFilter.FOREVER : wsTimeout,

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-client

WebSocketHolder.set(ctx.getConnection(), context.protocolHandler, ws);
((WebSocketUpgradeHandler) context.getAsyncHandler()).onSuccess(context.webSocket);
final int wsTimeout = provider.getClientConfig().getWebSocketTimeout();
IdleTimeoutFilter.setCustomTimeout(ctx.getConnection(),
    (wsTimeout <= 0) ? IdleTimeoutFilter.FOREVER : wsTimeout,

相关文章

微信公众号

最新文章

更多