Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adding examples of managing the websocket extensions

This commit is contained in:
Joakim Erdfelt 2014-02-19 11:32:07 -07:00
parent 6b1f17b503
commit 395e8f1c8b
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
jetty-websocket/websocket-server/src/test/java/org/eclipse/jetty/websocket/server/browser/BrowserDebugTool.java
View File

@ -83,8 +83,9 @@ public class BrowserDebugTool implements WebSocketCreator
String ua = req.getHeader("User-Agent"); String ua = req.getHeader("User-Agent");
String rexts = req.getHeader("Sec-WebSocket-Extensions"); String rexts = req.getHeader("Sec-WebSocket-Extensions");
LOG.debug("User-Agent: {}", ua); LOG.debug("User-Agent: {}", ua);
LOG.debug("Sec-WebSocket-Extensions: {}", rexts); LOG.debug("Sec-WebSocket-Extensions (Request) : {}", rexts);
return new BrowserSocket(ua,rexts); return new BrowserSocket(ua,rexts);
} }
@ -113,6 +114,10 @@ public class BrowserDebugTool implements WebSocketCreator
{ {
LOG.debug("Configuring WebSocketServerFactory ..."); LOG.debug("Configuring WebSocketServerFactory ...");
// factory.getExtensionFactory().unregister("deflate-frame");
// factory.getExtensionFactory().unregister("permessage-deflate");
// factory.getExtensionFactory().unregister("x-webkit-deflate-frame");
// Setup the desired Socket to use for all incoming upgrade requests // Setup the desired Socket to use for all incoming upgrade requests
factory.setCreator(BrowserDebugTool.this); factory.setCreator(BrowserDebugTool.this);

6
jetty-websocket/websocket-server/src/test/java/org/eclipse/jetty/websocket/server/browser/BrowserSocket.java
View File

@ -135,8 +135,10 @@ public class BrowserSocket
} }
else else
{ {
writeMessage("Client Sec-WebSocket-Extensions: " + this.requestedExtensions); writeMessage("Client requested Sec-WebSocket-Extensions: " + this.requestedExtensions);
writeMessage("Negotiated Sec-WebSocket-Extensions: " + session.getUpgradeResponse().getHeader("Sec-WebSocket-Extensions"));
} }
break; break;
} }
case "many": case "many":
@ -225,7 +227,7 @@ public class BrowserSocket
} }
// Async write // Async write
session.getRemote().sendString(message, null); session.getRemote().sendString(message,null);
} }
private void writeMessage(String format, Object... args) private void writeMessage(String format, Object... args)