Comet transport need to send the connectionID for bi-directional comm…

…unication
mkaluzny · Oct 25, 2012 · 9e5c9fe · 9e5c9fe
1 parent 97c8f55
commit 9e5c9fe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...tmosphere-gwt-client/src/main/java/org/atmosphere/gwt/client/impl/BaseCometTransport.java b/...tmosphere-gwt-client/src/main/java/org/atmosphere/gwt/client/impl/BaseCometTransport.java
@@ -109,6 +109,7 @@ public RPCServerTransport(AtmosphereGWTSerializer serializer) {
         @Override
         void send(String message, final AsyncCallback<Void> callback) {
             RequestBuilder request = new RequestBuilder(RequestBuilder.POST, serviceUrl());
+            request.setHeader("connectionID", connectionUUID);
             try {
                 logger.fine("Sending message to server: " + message);
                 request.sendRequest(message, new RequestCallback() {

diff --git a/...s/atmosphere-gwt-server/src/main/java/org/atmosphere/gwt/server/AtmosphereGwtHandler.java b/...s/atmosphere-gwt-server/src/main/java/org/atmosphere/gwt/server/AtmosphereGwtHandler.java
@@ -215,7 +215,8 @@ public void onRequest(AtmosphereResource resource) throws IOException {
         String servertransport = request.getParameter("servertransport");
         Object webSocketSubProtocol = resource.getRequest().getAttribute(FrameworkConfig.WEBSOCKET_SUBPROTOCOL);
         if ("rpcprotocol".equals(servertransport)) {
-            doServerMessage(request, resource.getResponse(), resource.uuid());
+            String connectionID = request.getHeader("connectionID");
+            doServerMessage(request, resource.getResponse(), connectionID);
             return;
 
         } else if (webSocketSubProtocol != null