@@ -133,7 +133,7 @@ public static ProxyConnector createIoProxyConnector(SocketConnector socketConnec
133
133
connector .setConnectTimeoutMillis (5000 );
134
134
135
135
if (proxyType .equalsIgnoreCase ("http" )) {
136
- req = createHttpProxyRequest (address , proxyVersion , proxyUser , proxyDomain , proxyWorkstation );
136
+ req = createHttpProxyRequest (address , proxyVersion , proxyUser , proxyPassword , proxyDomain , proxyWorkstation );
137
137
} else if (proxyType .equalsIgnoreCase ("socks" )) {
138
138
req = createSocksProxyRequest (address , proxyVersion , proxyUser , proxyPassword );
139
139
} else {
@@ -157,12 +157,13 @@ public static ProxyConnector createIoProxyConnector(SocketConnector socketConnec
157
157
private static ProxyRequest createHttpProxyRequest (InetSocketAddress address ,
158
158
String proxyVersion ,
159
159
String proxyUser ,
160
+ String proxyPassword ,
160
161
String proxyDomain ,
161
162
String proxyWorkstation ) {
162
163
String uri = "http://" + address .getAddress ().getHostAddress () + ":" + address .getPort ();
163
164
HashMap <String , String > props = new HashMap <>();
164
165
props .put (HttpProxyConstants .USER_PROPERTY , proxyUser );
165
- props .put (HttpProxyConstants .PWD_PROPERTY , proxyUser );
166
+ props .put (HttpProxyConstants .PWD_PROPERTY , proxyPassword );
166
167
if (proxyDomain != null && proxyWorkstation != null ) {
167
168
props .put (HttpProxyConstants .DOMAIN_PROPERTY , proxyDomain );
168
169
props .put (HttpProxyConstants .WORKSTATION_PROPERTY , proxyWorkstation );
0 commit comments