[jboss-cvs] JBossAS SVN: r103873 - projects/test/trunk/src/main/java/org/jboss/test/jms.

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

Author: clebert.suconic at jboss.com
Date: 2010-04-12 23:50:46 -0400 (Mon, 12 Apr 2010)
New Revision: 103873

Modified:
   projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java
Log:
fixing hornetq admin

Modified: projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java
===================================================================
--- projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java	2010-04-13 03:28:49 UTC (rev 103872)
+++ projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java	2010-04-13 03:50:46 UTC (rev 103873)
@@ -172,12 +172,10 @@
 
    public void createQueue(String name, String[] jndiArray, TestRole... securityConfig) throws Exception
    {
-      for (String jndi : jndiArray)
-      {
-         jmx.invoke(hornetQJMSServerName, "createQueue", new Object[]
-         { name, jndi }, new String[]
-         { "java.lang.String", "java.lang.String" });
-      }
+	  
+     jmx.invoke(hornetQJMSServerName, "createQueue", new Object[]
+     { name, commaSeparated(jndiArray) }, new String[]
+     { "java.lang.String", "java.lang.String" });
 
       addRoles(getCoreAddress(false, name), securityConfig);
 
@@ -192,12 +190,9 @@
 
    public void createTopic(String name, String[] jndiArray, TestRole... securityConfig) throws Exception
    {
-      for (String jndi : jndiArray)
-      {
-         jmx.invoke(hornetQJMSServerName, "createTopic", new Object[]
-         { name, jndi }, new String[]
-         { "java.lang.String", "java.lang.String" });
-      }
+     jmx.invoke(hornetQJMSServerName, "createTopic", new Object[]
+     { name, commaSeparated(jndiArray)}, new String[]
+     { "java.lang.String", "java.lang.String" });
 
       addRoles(getCoreAddress(true, name), securityConfig);
 
@@ -325,4 +320,17 @@
       }
    }
 
+   private String commaSeparated(String [] elements)
+   {
+	   StringBuffer list = new StringBuffer();
+	   
+	   for (int i = 0 ; i < elements.length; i++)
+	   {
+		   list.append(elements[i]);
+		   if (i+1 < elements.length)
+			   list.append(",");
+	   }
+	   return list.toString();
+   }
+   
 }