[jboss-svn-commits] JBL Code SVN: r6943 - labs/jbossesb/workspace/eschifman/trunk/product/core/rosetta/src/org/jboss/soa/esb/util

[jboss-svn-commits at lists.jboss.org]

Author: estebanschifman
Date: 2006-10-20 06:51:37 -0400 (Fri, 20 Oct 2006)
New Revision: 6943

Modified:
   labs/jbossesb/workspace/eschifman/trunk/product/core/rosetta/src/org/jboss/soa/esb/util/Util.java
Log:
New reusable method propertiesFromSelector(String selector)

Modified: labs/jbossesb/workspace/eschifman/trunk/product/core/rosetta/src/org/jboss/soa/esb/util/Util.java
===================================================================
--- labs/jbossesb/workspace/eschifman/trunk/product/core/rosetta/src/org/jboss/soa/esb/util/Util.java	2006-10-20 08:19:22 UTC (rev 6942)
+++ labs/jbossesb/workspace/eschifman/trunk/product/core/rosetta/src/org/jboss/soa/esb/util/Util.java	2006-10-20 10:51:37 UTC (rev 6943)
@@ -28,7 +28,9 @@
 import java.io.PrintStream;
 import java.io.Serializable;
 import java.io.StringWriter;
+import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.List;
 
 import javax.xml.parsers.DocumentBuilder;
 import javax.xml.parsers.DocumentBuilderFactory;
@@ -42,6 +44,7 @@
 import org.apache.xml.serialize.XMLSerializer;
 import org.jboss.internal.soa.esb.message.format.serialized.MessageImpl;
 import org.jboss.soa.esb.common.ModulePropertyManager;
+import org.jboss.soa.esb.helpers.KeyValuePair;
 import org.jboss.soa.esb.message.Message;
 import org.w3c.dom.Document;
 import org.xml.sax.SAXException;
@@ -171,4 +174,23 @@
 		return message;
 	} //________________________________
 
+    public static List<KeyValuePair> propertiesFromSelector(String selector) throws Exception 
+    {
+		// No problem if selector is null - everything in queue will be returned
+		List<KeyValuePair> oRet = new ArrayList<KeyValuePair>();
+		if (! Util.isNullString(selector))
+			for (String sCurr : selector.split(","))
+			{
+				String[] sa = sCurr.split("=");
+				if (sa.length!=2
+				||  sa[1].charAt(0)!='\''
+				||  sa[1].charAt(-1+sa[1].length())!='\'')
+					throw new Exception("Illegal message selector syntax <"+selector+">");
+				KeyValuePair oNew = new KeyValuePair
+					(sa[0],sa[1].substring(0,-1+sa[1].length()).substring(1));
+				oRet.add(oNew);
+			}
+		return oRet;
+    } //________________________________
+    
 } // ____________________________________________________________________________