[jboss-cvs] JBossAS SVN: r102636 - 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-03-19 15:40:22 -0400 (Fri, 19 Mar 2010)
New Revision: 102636

Modified:
   projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java
   projects/test/trunk/src/main/java/org/jboss/test/jms/LegacyJMSTestAdmin.java
Log:
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-03-19 19:13:19 UTC (rev 102635)
+++ projects/test/trunk/src/main/java/org/jboss/test/jms/HornetQTestAdmin.java	2010-03-19 19:40:22 UTC (rev 102636)
@@ -57,25 +57,23 @@
       jmx = (MBeanServerConnection) ctx.lookup(adaptorName);
       ctx.close();
    }
-   
+
    @Override
    public boolean isSupported()
    {
       try
       {
-           createQueue("deleteMe");
-           destroyCreatedDestinations();
-           for (int i = 0 ; i < 100; i++) staticLog.info("HornetQ is supported!!!");
-           return true;
-      }
-      catch (Exception e)
+         createQueue("deleteMe");
+         destroyCreatedDestinations();
+         staticLog.info("HornetQ is supported");
+         return true;
+      } catch (Exception e)
       {
          staticLog.debug("HornetQTestAdmin is not support because an exception happened", e);
          return false;
       }
    }
 
-   
    public void createQueue(String name, TestRole... securityConfig) throws Exception
    {
       createQueue(name, new String[]
@@ -138,10 +136,8 @@
       }
 
       jmx.invoke(hornetQCoreServerName, "addSecuritySettings", new Object[]
-      { address, sendRoles, consumeRoles, createDurableQueueRoles, deleteDurableQueueRoles, createTempQueueRoles,
-            deleteTempQueueRoles, manageRoles }, new String[]
-      { String.class.getName(), String.class.getName(), String.class.getName(), String.class.getName(), String.class.getName(),
-            String.class.getName(), String.class.getName(), String.class.getName() });
+      { address, sendRoles, consumeRoles, createDurableQueueRoles, deleteDurableQueueRoles, createTempQueueRoles, deleteTempQueueRoles, manageRoles }, new String[]
+      { String.class.getName(), String.class.getName(), String.class.getName(), String.class.getName(), String.class.getName(), String.class.getName(), String.class.getName(), String.class.getName() });
    }
 
    private boolean isEmpty(String str)
@@ -239,7 +235,7 @@
    public void destroyEveryDestination() throws Exception
    {
       String[] queues = (String[]) jmx.getAttribute(hornetQJMSServerName, "QueueNames");
-      
+
       for (String queue : queues)
       {
          if (!queue.equals("DLQ") && !queue.equals("ExpiryQueue"))
@@ -249,7 +245,7 @@
       }
 
       String[] topics = (String[]) jmx.getAttribute(hornetQJMSServerName, "TopicNames");
-      
+
       for (String topic : topics)
       {
          deleteTopic(topic);

Modified: projects/test/trunk/src/main/java/org/jboss/test/jms/LegacyJMSTestAdmin.java
===================================================================
--- projects/test/trunk/src/main/java/org/jboss/test/jms/LegacyJMSTestAdmin.java	2010-03-19 19:13:19 UTC (rev 102635)
+++ projects/test/trunk/src/main/java/org/jboss/test/jms/LegacyJMSTestAdmin.java	2010-03-19 19:40:22 UTC (rev 102636)
@@ -63,7 +63,7 @@
          createQueue("deleteMeTest");
          destroyCreatedDestinations();
          
-         for (int i = 0 ; i < 100; i++) staticLog.info("Legacy is supported!!!");
+         staticLog.info("Legacy is supported!!!");
 
          return true;
       } catch (Throwable e)