Skip to content

Commit b4616f2

Browse files
committed
Fix WS timeout.
1 parent f30cf91 commit b4616f2

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/main/java/com/ning/http/client/providers/grizzly/GrizzlyAsyncHttpProvider.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ protected <T> ListenableFuture<T> execute(final Connection c,
306306
}
307307

308308

309-
protected void initializeTransport(AsyncHttpClientConfig clientConfig) {
309+
protected void initializeTransport(final AsyncHttpClientConfig clientConfig) {
310310

311311
final FilterChainBuilder fcb = FilterChainBuilder.stateless();
312312
fcb.add(new AsyncHttpClientTransportFilter());
@@ -326,6 +326,9 @@ public long getTimeout(FilterChainContext ctx) {
326326
final HttpTransactionContext context =
327327
GrizzlyAsyncHttpProvider.this.getHttpTransactionContext(ctx.getConnection());
328328
if (context != null) {
329+
if (context.isWSRequest) {
330+
return clientConfig.getWebSocketIdleTimeoutInMs();
331+
}
329332
final PerRequestConfig config = context.request.getPerRequestConfig();
330333
if (config != null) {
331334
final long timeout = config.getRequestTimeoutInMs();

0 commit comments

Comments
 (0)