Changeset 9276

Timestamp:

2005-03-04T13:26:17+13:00 (19 years ago)

Author:

kjdon

Message:

can now send the same message to several modules - use a comma separated list in the to field.

File:

• trunk/gsdl3/src/java/org/greenstone/gsdl3/core/MessageRouter.java (modified) (1 diff)

trunk/gsdl3/src/java/org/greenstone/gsdl3/core/MessageRouter.java

@@ -257 +257 @@
         mainResult.appendChild(this.doc.importNode(result, true));
         } else {
-        // find the module to pass it on to
-        // need to put the request into a message element
-        Element mess = message_doc.createElement(GSXML.MESSAGE_ELEM);
-        mess.appendChild(req);
-        String obj = GSPath.getFirstLink(path);
-        if (this.module_map.containsKey(obj)) {
-            result = ((ModuleInterface)this.module_map.get(obj)).process(mess);
-            if (result !=null ) {
-            // append the contents of the message to the mainResult - there will only be one response at this stage
-            mainResult.appendChild(this.doc.importNode(GSXML.getChildByTagName(result, GSXML.RESPONSE_ELEM), true));
-            } else {
-            System.err.println("MessageRouter Error: request had null result!");
+        String [] modules = path.split(",");
+        for (int j=0; j<modules.length; j++) {
+            String this_mod = modules[j];
+            // find the module to pass it on to
+            // need to put the request into a message element
+            Element mess = message_doc.createElement(GSXML.MESSAGE_ELEM);
+            req.setAttribute(GSXML.TO_ATT, this_mod);
+            mess.appendChild(req);
+            String obj = GSPath.getFirstLink(this_mod);
+            if (this.module_map.containsKey(obj)) {
+            result = ((ModuleInterface)this.module_map.get(obj)).process(mess);
+            if (result !=null ) {
+                // append the contents of the message to the mainResult - there will only be one response at this stage
+                mainResult.appendChild(this.doc.importNode(GSXML.getChildByTagName(result, GSXML.RESPONSE_ELEM), true));
+            } else {
+                // add in a place holder response
+                Element response = this.doc.createElement(GSXML.RESPONSE_ELEM);
+                response.setAttribute(GSXML.FROM_ATT, this_mod);
+                mainResult.appendChild(response);
+                System.err.println("MessageRouter Error: request had null result!");
+            }
+            
+            } else {    
+            System.err.println("MessageRouter Error: request has illegal module name in:\n"+this.converter.getString(req));
             }
-        } else {    
-            System.err.println("MessageRouter Error: request has illegal module name in:\n"+this.converter.getString(req));
         }
         }