|
16 | 16 |
|
17 | 17 | package org.springframework.web.context.request.async;
|
18 | 18 |
|
| 19 | +import java.io.IOException; |
19 | 20 | import java.util.ArrayList;
|
20 | 21 | import java.util.LinkedHashMap;
|
21 | 22 | import java.util.List;
|
|
34 | 35 | import org.springframework.util.Assert;
|
35 | 36 | import org.springframework.web.context.request.RequestAttributes;
|
36 | 37 | import org.springframework.web.context.request.async.DeferredResult.DeferredResultHandler;
|
37 |
| -import org.springframework.web.util.DisconnectedClientHelper; |
38 | 38 |
|
39 | 39 | /**
|
40 | 40 | * The central class for managing asynchronous request processing, mainly intended
|
@@ -343,7 +343,7 @@ public void startCallableProcessing(final WebAsyncTask<?> webAsyncTask, Object..
|
343 | 343 | if (logger.isDebugEnabled()) {
|
344 | 344 | logger.debug("Servlet container error notification for " + formatUri(this.asyncWebRequest) + ": " + ex);
|
345 | 345 | }
|
346 |
| - if (DisconnectedClientHelper.isClientDisconnectedException(ex)) { |
| 346 | + if (ex instanceof IOException) { |
347 | 347 | ex = new AsyncRequestNotUsableException(
|
348 | 348 | "Servlet container error notification for disconnected client", ex);
|
349 | 349 | }
|
@@ -439,7 +439,7 @@ public void startDeferredResultProcessing(
|
439 | 439 | if (logger.isDebugEnabled()) {
|
440 | 440 | logger.debug("Servlet container error notification for " + formatUri(this.asyncWebRequest));
|
441 | 441 | }
|
442 |
| - if (DisconnectedClientHelper.isClientDisconnectedException(ex)) { |
| 442 | + if (ex instanceof IOException) { |
443 | 443 | ex = new AsyncRequestNotUsableException(
|
444 | 444 | "Servlet container error notification for disconnected client", ex);
|
445 | 445 | }
|
|
0 commit comments