Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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;
- }
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement