@@ -1033,7 +1033,7 @@ public void messageReceived(final ChannelHandlerContext ctx, MessageEvent e) thr
1033
1033
Realm realm = request .getRealm () != null ? request .getRealm () : config .getRealm ();
1034
1034
1035
1035
HttpResponseStatus status = new ResponseStatus (future .getURI (), response , this );
1036
- FilterContext fc = new FilterContext .FilterContextBuilder ().asyncHandler (handler ).request (request ).responseStatus (status ).build ();
1036
+ FilterContext <?> fc = new FilterContext .FilterContextBuilder ().asyncHandler (handler ).request (request ).responseStatus (status ).build ();
1037
1037
for (ResponseFilter asyncFilter : config .getResponseFilters ()) {
1038
1038
try {
1039
1039
fc = asyncFilter .filter (fc );
@@ -1248,7 +1248,7 @@ public Object call() throws Exception {
1248
1248
}
1249
1249
} catch (Exception t ) {
1250
1250
if (IOException .class .isAssignableFrom (t .getClass ()) && config .getIOExceptionFilters ().size () > 0 ) {
1251
- FilterContext fc = new FilterContext .FilterContextBuilder ().asyncHandler (future .getAsyncHandler ())
1251
+ FilterContext <?> fc = new FilterContext .FilterContextBuilder ().asyncHandler (future .getAsyncHandler ())
1252
1252
.request (future .getRequest ()).ioException (IOException .class .cast (t )).build ();
1253
1253
fc = handleIoException (fc , future );
1254
1254
@@ -1316,14 +1316,7 @@ private Realm ntlmChallenge(List<String> wwwAuth,
1316
1316
String challengeHeader = ntlmEngine .generateType1Msg (ntlmDomain , ntlmHost );
1317
1317
1318
1318
headers .add (HttpHeaders .Names .AUTHORIZATION , "NTLM " + challengeHeader );
1319
-
1320
- Realm .RealmBuilder realmBuilder ;
1321
- if (realm != null ) {
1322
- realmBuilder = new Realm .RealmBuilder ().clone (realm ).setScheme (realm .getAuthScheme ());
1323
- } else {
1324
- realmBuilder = new Realm .RealmBuilder ();
1325
- }
1326
- newRealm = realmBuilder
1319
+ newRealm = new Realm .RealmBuilder ().clone (realm ).setScheme (realm .getAuthScheme ())
1327
1320
.setUri (URI .create (request .getUrl ()).getPath ())
1328
1321
.setMethodName (request .getMethod ())
1329
1322
.setNtlmMessageType2Received (true )
@@ -1472,7 +1465,7 @@ public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws
1472
1465
future .touch ();
1473
1466
1474
1467
if (config .getIOExceptionFilters ().size () > 0 ) {
1475
- FilterContext fc = new FilterContext .FilterContextBuilder ().asyncHandler (future .getAsyncHandler ())
1468
+ FilterContext <?> fc = new FilterContext .FilterContextBuilder ().asyncHandler (future .getAsyncHandler ())
1476
1469
.request (future .getRequest ()).ioException (new IOException ("Channel Closed" )).build ();
1477
1470
fc = handleIoException (fc , future );
1478
1471
@@ -1600,7 +1593,7 @@ public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)
1600
1593
if (IOException .class .isAssignableFrom (cause .getClass ())) {
1601
1594
1602
1595
if (config .getIOExceptionFilters ().size () > 0 ) {
1603
- FilterContext fc = new FilterContext .FilterContextBuilder ().asyncHandler (future .getAsyncHandler ())
1596
+ FilterContext <?> fc = new FilterContext .FilterContextBuilder ().asyncHandler (future .getAsyncHandler ())
1604
1597
.request (future .getRequest ()).ioException (new IOException ("Channel Closed" )).build ();
1605
1598
fc = handleIoException (fc , future );
1606
1599
0 commit comments