diff --git a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf00/Ietf00Handshake.java b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf00/Ietf00Handshake.java index 3e3da98a..cd05337a 100644 --- a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf00/Ietf00Handshake.java +++ b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf00/Ietf00Handshake.java @@ -63,7 +63,7 @@ public HttpRequest generateRequest(URI uri) throws Exception { request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" ); request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" ); request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() ); - request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" ); + request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "v11.stomp" ); request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_KEY1, this.challenge.getKey1String() ); request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_KEY2, this.challenge.getKey2String() ); diff --git a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf07/Ietf07Handshake.java b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf07/Ietf07Handshake.java index 4fe7cbc2..54b1e3b2 100644 --- a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf07/Ietf07Handshake.java +++ b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf07/Ietf07Handshake.java @@ -68,7 +68,7 @@ public HttpRequest generateRequest(URI uri) throws Exception { request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" ); request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" ); request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() ); - request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" ); + request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "v11.stomp" ); request.addHeader( "Sec-WebSocket-Key", this.challenge.getNonceBase64() ); request.setContent( ChannelBuffers.EMPTY_BUFFER ); diff --git a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf08/Ietf08Handshake.java b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf08/Ietf08Handshake.java index 9ccdb5d2..d169fd15 100644 --- a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf08/Ietf08Handshake.java +++ b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf08/Ietf08Handshake.java @@ -72,7 +72,7 @@ public HttpRequest generateRequest(URI uri) throws Exception { request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" ); request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" ); request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() ); - request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" ); + request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "v11.stomp" ); request.addHeader( "Sec-WebSocket-Key", this.challenge.getNonceBase64() ); request.setContent( ChannelBuffers.EMPTY_BUFFER ); diff --git a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf17/Ietf17Handshake.java b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf17/Ietf17Handshake.java index 6f7280a9..97861d7f 100644 --- a/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf17/Ietf17Handshake.java +++ b/stomp-common/src/main/java/org/projectodd/stilts/stomp/protocol/websocket/ietf17/Ietf17Handshake.java @@ -72,7 +72,7 @@ public HttpRequest generateRequest(URI uri) throws Exception { request.addHeader( HttpHeaders.Names.CONNECTION, "Upgrade" ); request.addHeader( HttpHeaders.Names.UPGRADE, "WebSocket" ); request.addHeader( HttpHeaders.Names.HOST, uri.getHost()+ ":" + uri.getPort() ); - request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "stomp" ); + request.addHeader( HttpHeaders.Names.SEC_WEBSOCKET_PROTOCOL, "v11.stomp" ); request.addHeader( "Sec-WebSocket-Key", this.challenge.getNonceBase64() ); request.setContent( ChannelBuffers.EMPTY_BUFFER );