Fix for AsyncHttpClient#190.

rlubke · rlubke · commit d3aebfc9194b · 2012-12-27T13:58:58.000-08:00
diff --git a/providers/grizzly/src/main/java/com/ning/http/client/providers/grizzly/GrizzlyAsyncHttpProvider.java b/providers/grizzly/src/main/java/com/ning/http/client/providers/grizzly/GrizzlyAsyncHttpProvider.java
@@ -844,7 +844,8 @@ private boolean sendAsGrizzlyRequest(final Request request,
             }
             final URI uri = AsyncHttpProviderUtils.createUri(httpCtx.requestUrl);
             final HttpRequestPacket.Builder builder = HttpRequestPacket.builder();
-            boolean secure = "https".equals(uri.getScheme());
+            final String scheme = uri.getScheme();
+            boolean secure = "https".equals(scheme) || "wss".equals(scheme);
             builder.method(request.getMethod());
             builder.protocol(Protocol.HTTP_1_1);
             String host = request.getVirtualHost();
@@ -861,6 +862,7 @@ private boolean sendAsGrizzlyRequest(final Request request,
             final boolean useProxy = (proxy != null);
             if (useProxy) {
                 if ((secure || httpCtx.isWSRequest) && !httpCtx.isTunnelEstablished(ctx.getConnection())) {
+                    ctx.notifyDownstream(new SwitchingSSLFilter.SSLSwitchingEvent(false, ctx.getConnection()));
                     secure = false;
                     httpCtx.establishingTunnel = true;
                     builder.method(Method.CONNECT);
