本文整理了Java中com.ning.http.client.AsyncHttpClientConfig.getWebSocketTimeout()
方法的一些代码示例,展示了AsyncHttpClientConfig.getWebSocketTimeout()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AsyncHttpClientConfig.getWebSocketTimeout()
方法的具体详情如下:
包路径:com.ning.http.client.AsyncHttpClientConfig
类名称: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,
内容来源于网络,如有侵权,请联系作者删除!