activemq jetty9 patch

diff --git a/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/WSServlet.java b/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/WSServlet.java
index 15927b1..e4792f4 100644
--- a/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/WSServlet.java
+++ b/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/WSServlet.java
@@ -23,6 +23,7 @@ import javax.servlet.ServletException;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;

+import org.apache.activemq.transport.Transport;
 import org.apache.activemq.transport.TransportAcceptListener;
 import org.eclipse.jetty.websocket.api.WebSocketListener;
 import org.eclipse.jetty.websocket.servlet.ServletUpgradeRequest;
@@ -60,9 +61,12 @@ public class WSServlet extends WebSocketServlet {
                 WebSocketListener socket;
                 if (req.getSubProtocols().contains("mqtt")) {
                     socket = new MQTTSocket();
+                    resp.setAcceptedSubProtocol("mqtt");
                 } else {
                     socket = new StompSocket();
+                    resp.setAcceptedSubProtocol("stomp");
                 }
+                listener.onAccept((Transport)socket);
                 return socket;
             }
         });