[jboss-cvs] JBossAS SVN: r105787 - branches/JBPAPP_5_1/testsuite/src/main/org/jboss/test/jbossmessaging/test.

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

Author: clebert.suconic at jboss.com
Date: 2010-06-07 16:12:28 -0400 (Mon, 07 Jun 2010)
New Revision: 105787

Modified:
   branches/JBPAPP_5_1/testsuite/src/main/org/jboss/test/jbossmessaging/test/SecurityUnitTestCase.java
Log:
Fixing test

Modified: branches/JBPAPP_5_1/testsuite/src/main/org/jboss/test/jbossmessaging/test/SecurityUnitTestCase.java
===================================================================
--- branches/JBPAPP_5_1/testsuite/src/main/org/jboss/test/jbossmessaging/test/SecurityUnitTestCase.java	2010-06-07 20:01:19 UTC (rev 105786)
+++ branches/JBPAPP_5_1/testsuite/src/main/org/jboss/test/jbossmessaging/test/SecurityUnitTestCase.java	2010-06-07 20:12:28 UTC (rev 105787)
@@ -282,7 +282,14 @@
          int ic = 5;
          // Publish
          IntRangeMessageCreator c1 = new IntRangeMessageCreator("USER_NR", 0);
-         pub1 = new TopicWorker(PUBLISHER, TRANS_NONE, c1, ic, PRECONF_CLIENT_IDCONNECTIONFACTORY);
+  	     if (JMSDestinationsUtil.isHornetQ())
+  	     {
+  	        pub1 = new TopicWorker(PUBLISHER, TRANS_NONE, c1, ic, PRECONF_CLIENT_IDCONNECTIONFACTORY);
+  	     }
+  	     else
+	     {
+            pub1 = new TopicWorker(PUBLISHER, TRANS_NONE, c1, ic);
+         }
          pub1.setUser("john", "needle");
          pub1.connect();
          pub1.publish();
@@ -1009,7 +1016,14 @@
          int ic = 5;
          // Set up a durable subscriber
          IntRangeMessageFilter f1 = new IntRangeMessageFilter(javax.jms.Message.class, "DURABLE_NR", 0, ic);
-         sub1 = new TopicWorker(SUBSCRIBER, TRANS_NONE, f1, PRECONF_CLIENT_IDCONNECTIONFACTORY);
+         if (JMSDestinationsUtil.isHornetQ())
+         {
+        	 sub1 = new TopicWorker(SUBSCRIBER, TRANS_NONE, f1, PRECONF_CLIENT_IDCONNECTIONFACTORY);
+         }
+         else
+         {
+        	 sub1 = new TopicWorker(SUBSCRIBER, TRANS_NONE, f1);
+         }
          sub1.setDurable("john", "needle", "sub2");
          Thread t1 = new Thread(sub1);
          t1.start();
@@ -1068,7 +1082,16 @@
          int ic = 5;
          // Set up a durable subscriber
          IntRangeMessageFilter f1 = new IntRangeMessageFilter(javax.jms.Message.class, "DURABLE_NR", 0, ic);
-         sub1 = new TopicWorker(SUBSCRIBER, TRANS_NONE, f1, PRECONF_CLIENT_IDCONNECTIONFACTORY);
+         
+         if (JMSDestinationsUtil.isHornetQ())
+         {
+             sub1 = new TopicWorker(SUBSCRIBER, TRANS_NONE, f1, PRECONF_CLIENT_IDCONNECTIONFACTORY);
+         }
+         else
+         {
+             sub1 = new TopicWorker(SUBSCRIBER, TRANS_NONE, f1);
+         }
+         
          sub1.setDurable("john", "needle", "sub3");
          Thread t1 = new Thread(sub1);
          t1.start();