[jboss-cvs] JBossAS SVN: r101599 - 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-02-26 19:10:29 -0500 (Fri, 26 Feb 2010)
New Revision: 101599

Modified:
   projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java
   projects/test/trunk/src/main/java/org/jboss/test/jms/JMSTestAdmin.java
Log:
small tweaks

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-02-26 20:49:17 UTC (rev 101598)
+++ projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java	2010-02-27 00:10:29 UTC (rev 101599)
@@ -60,7 +60,7 @@
 
    public void createQueue(String name, TestRole... securityConfig) throws Exception
    {
-      createQueue(name, "/queue/" + name, securityConfig);
+      createQueue(name, new String[] {"/queue/" + name, name}, securityConfig);
    }
 
    private void addRoles(String address, TestRole[] securityConf) throws Exception
@@ -151,11 +151,14 @@
 
    }
 
-   public void createQueue(String name, String jndi, TestRole... securityConfig) throws Exception
+   public void createQueue(String name, String[] jndiArray, TestRole... securityConfig) throws Exception
    {
-      jmx.invoke(hornetQJMSServerName, "createQueue", new Object[]
-      { name, jndi }, new String[]
-      { "java.lang.String", "java.lang.String" });
+      for (String jndi: jndiArray)
+      {
+         jmx.invoke(hornetQJMSServerName, "createQueue", new Object[]
+         { name, jndi }, new String[]
+         { "java.lang.String", "java.lang.String" });
+      }
 
       addRoles(getCoreAddress(false, name), securityConfig);
 
@@ -164,14 +167,17 @@
 
    public void createTopic(String name, TestRole... securityConfig) throws Exception
    {
-      createTopic(name, "/topic/" + name, securityConfig);
+      createTopic(name, new String[]{"/topic/" + name, name}, securityConfig);
    }
 
-   public void createTopic(String name, String jndi, TestRole... securityConfig) throws Exception
+   public void createTopic(String name, String[] jndiArray, TestRole... securityConfig) throws Exception
    {
-      jmx.invoke(hornetQJMSServerName, "createTopic", new Object[]
-      { name, jndi }, new String[]
-      { "java.lang.String", "java.lang.String" });
+      for (String jndi: jndiArray)
+      {
+         jmx.invoke(hornetQJMSServerName, "createTopic", new Object[]
+         { name, jndi }, new String[]
+         { "java.lang.String", "java.lang.String" });
+      }
 
       addRoles(getCoreAddress(true, name), securityConfig);
 

Modified: projects/test/trunk/src/main/java/org/jboss/test/jms/JMSTestAdmin.java
===================================================================
--- projects/test/trunk/src/main/java/org/jboss/test/jms/JMSTestAdmin.java	2010-02-26 20:49:17 UTC (rev 101598)
+++ projects/test/trunk/src/main/java/org/jboss/test/jms/JMSTestAdmin.java	2010-02-27 00:10:29 UTC (rev 101599)
@@ -71,13 +71,13 @@
 	 */
    public abstract void createTopic(String name, TestRole ... securityConfig) throws Exception;
 
-   public abstract void createTopic(String name, String jndi, TestRole ... securityConfig) throws Exception;
+   public abstract void createTopic(String name, String[] jndi, TestRole ... securityConfig) throws Exception;
 
 	public abstract void deleteTopic(String topic) throws Exception;
 
 	public abstract void createQueue(String name, TestRole ... securityConfig) throws Exception;
 
-   public abstract void createQueue(String name, String jndi, TestRole ... securityConfig) throws Exception;
+   public abstract void createQueue(String name, String[] jndi, TestRole ... securityConfig) throws Exception;
 
    public abstract void deleteQueue(String queue) throws Exception;