New services

[gpl/argeo-slc.git] / org.argeo.slc.webapp / src / main / webapp / argeo-ria-src / class / org / argeo / ria / remote / JmsClient.js

diff --git a/org.argeo.slc.webapp/src/main/webapp/argeo-ria-src/class/org/argeo/ria/remote/JmsClient.js b/org.argeo.slc.webapp/src/main/webapp/argeo-ria-src/class/org/argeo/ria/remote/JmsClient.js
index 792b87c164c2e5b5b6f7f97cb35b0d1c531cab38..bcf6e3a6d90d3e46fd431e84ed25b295c584760d 100644 (file)
--- a/org.argeo.slc.webapp/src/main/webapp/argeo-ria-src/class/org/argeo/ria/remote/JmsClient.js
+++ b/org.argeo.slc.webapp/src/main/webapp/argeo-ria-src/class/org/argeo/ria/remote/JmsClient.js
@@ -8,7 +8,7 @@ qx.Class.define("org.argeo.ria.remote.JmsClient", {
        },\r
        members : {\r
                // The URI of the MessageListenerServlet\r
-               uri : '/org.argeo.slc.webapp/amq',              \r
+               uri : '../amqMessage',          \r
 \r
                // Polling. Set to true (default) if waiting poll for messages is needed\r
                poll : true,\r
@@ -24,9 +24,8 @@ qx.Class.define("org.argeo.ria.remote.JmsClient", {
                _handlers : new Array(),\r
 \r
                _messageHandler : function(response) {\r
-                       var doc = response.getContent();\r
-                       var NSMap = {slc:"http://argeo.org/projects/slc/schemas"};\r
-                       var messages = org.argeo.ria.util.Element.selectNodes(doc, "//response", NSMap);\r
+                       var doc = response.getContent();                        \r
+                       var messages = org.argeo.ria.util.Element.selectNodes(doc, "//response");\r
                        for(var i=0;i<messages.length;i++){\r
                                var id = messages[i].getAttribute("id");\r
                                if(id && this._handlers[id]){\r
@@ -71,8 +70,8 @@ qx.Class.define("org.argeo.ria.remote.JmsClient", {
 \r
                // Send a JMS message to a destination (eg topic://MY.TOPIC).  Message should be xml or encoded\r
                // xml content.\r
-               sendMessage : function(destination, message) {\r
-                       this._sendMessage(destination, message, 'send');\r
+               sendMessage : function(destination, message, properties) {\r
+                       this._sendMessage(destination, message, 'send', properties);\r
                },\r
 \r
                // Listen on a channel or topic.   handler must be a function taking a message arguement\r
@@ -87,11 +86,16 @@ qx.Class.define("org.argeo.ria.remote.JmsClient", {
                        this._sendMessage(destination, id, 'unlisten');\r
                },\r
 \r
-               _sendMessage : function(destination, message, type) {\r
+               _sendMessage : function(destination, message, type, properties) {\r
                        var req = new qx.io.remote.Request(this.uri, "POST", "text/plain");\r
                        req.setParameter("destination", destination);\r
                        req.setParameter("message", message);\r
                        req.setParameter("type", type);\r
+                       if(properties){\r
+                               for(var key in properties){\r
+                                       req.setParameter(key, properties[key]);\r
+                               }\r
+                       }\r
                        //req.addListener("completed", this.endBatch, this);\r
                        req.send();\r
                },\r