@@ -70,11 +70,9 @@ private static class NTLM_INSTANCE_HOLDER {
70
70
private static final HeaderValue CLOSE_VALUE = HeaderValue .newHeaderValue ("close" );
71
71
72
72
private final AsyncHttpClientConfig config ;
73
- private final GrizzlyAsyncHttpProvider provider ;
74
73
75
74
// -------------------------------------------------------- Constructors
76
75
AsyncHttpClientFilter (final GrizzlyAsyncHttpProvider provider ) {
77
- this .provider = provider ;
78
76
this .config = provider .getClientConfig ();
79
77
}
80
78
@@ -124,22 +122,15 @@ private boolean sendAsGrizzlyRequest(final HttpTransactionContext httpTxCtx, fin
124
122
return establishConnectTunnel (proxy , httpTxCtx , uri , ctx );
125
123
}
126
124
final HttpRequestPacket .Builder builder = HttpRequestPacket .builder ().protocol (Protocol .HTTP_1_1 ).method (method );
127
- if (useProxy ) {
128
- if (secure || httpTxCtx .isWSRequest ) {
129
- // Sending message over established CONNECT tunnel
130
- if (config .isUseRelativeURIsWithConnectProxies ()) {
131
- builder .uri (AsyncHttpProviderUtils .getNonEmptyPath (uri ));
132
- builder .query (uri .getQuery ());
133
- } else {
134
- builder .uri (uri .toUrl ());
135
- }
136
- } else {
137
- builder .uri (uri .toUrl ());
138
- }
125
+
126
+ if (useProxy && !((secure || httpTxCtx .isWSRequest ) &&
127
+ config .isUseRelativeURIsWithConnectProxies ())) {
128
+ builder .uri (uri .toUrl ());
139
129
} else {
140
130
builder .uri (AsyncHttpProviderUtils .getNonEmptyPath (uri ));
141
131
builder .query (uri .getQuery ());
142
132
}
133
+
143
134
HttpRequestPacket requestPacket ;
144
135
final PayloadGenerator payloadGenerator = isPayloadAllowed (method ) ? PayloadGenFactory .getPayloadGenerator (ahcRequest ) : null ;
145
136
if (payloadGenerator != null ) {
0 commit comments