15
15
import java .time .Duration ;
16
16
import java .util .concurrent .ExecutionException ;
17
17
import java .util .concurrent .atomic .AtomicReference ;
18
+ import javax .servlet .ServletException ;
18
19
import javax .servlet .http .HttpServletRequest ;
19
20
import javax .servlet .http .HttpServletResponse ;
20
21
import org .eclipse .jetty .server .Handler ;
21
22
import org .eclipse .jetty .server .Request ;
22
23
import org .eclipse .jetty .server .Server ;
23
24
import org .eclipse .jetty .server .handler .AbstractHandler ;
25
+ import org .eclipse .jetty .server .handler .ErrorHandler ;
24
26
import org .junit .Ignore ;
25
27
import org .junit .Test ;
26
28
import org .reactivestreams .Publisher ;
@@ -245,7 +247,7 @@ private HttpExecuteResponse sendRequest(SdkAsyncHttpClient client, EmbeddedServe
245
247
throws IOException {
246
248
final AtomicReference <SdkHttpResponse > responseBuffer = new AtomicReference <>();
247
249
final ByteArrayOutputStream bodyBuffer = new ByteArrayOutputStream ();
248
- final URI serverUri = server .uri ();
250
+ final URI serverUri = server .uri ();
249
251
250
252
try {
251
253
SdkHttpRequest .Builder requestBuilder = SdkHttpRequest .builder ()
@@ -321,6 +323,15 @@ private static class EmbeddedServer implements SdkAutoCloseable {
321
323
public EmbeddedServer (Handler handler ) throws Exception {
322
324
server = new Server (0 );
323
325
server .setHandler (handler );
326
+ server .setErrorHandler (new ErrorHandler () {
327
+ @ Override
328
+ public void handle (String target , Request baseRequest , HttpServletRequest request ,
329
+ HttpServletResponse response ) throws IOException , ServletException {
330
+ System .err .println ("error handler" );
331
+ System .err .println (target );
332
+ super .handle (target , baseRequest , request , response );
333
+ }
334
+ });
324
335
server .start ();
325
336
}
326
337
@@ -330,6 +341,7 @@ public URI uri() {
330
341
331
342
@ Override
332
343
public void close () {
344
+ System .err .println ("EmbeddedServer#close" );
333
345
try {
334
346
server .stop ();
335
347
} catch (Exception e ) {
0 commit comments