[jboss-cvs] JBoss Messaging SVN: r6083 - trunk/tests/src/org/jboss/messaging/tests/unit/core/postoffice/impl.

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

Author: clebert.suconic at jboss.com
Date: 2009-03-13 12:41:04 -0400 (Fri, 13 Mar 2009)
New Revision: 6083

Modified:
   trunk/tests/src/org/jboss/messaging/tests/unit/core/postoffice/impl/BindingImplTest.java
Log:
tweak

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/postoffice/impl/BindingImplTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/postoffice/impl/BindingImplTest.java	2009-03-13 16:38:15 UTC (rev 6082)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/postoffice/impl/BindingImplTest.java	2009-03-13 16:41:04 UTC (rev 6083)
@@ -68,7 +68,7 @@
    public void testRemoveWhileRouting() throws Exception
    {
       // It would require many iterations before getting a failure
-      for (int i = 0; i < 100; i++)
+      for (int i = 0; i < 2000; i++)
       {
          internalTestRoute();
       }
@@ -77,9 +77,6 @@
    private void internalTestRoute() throws Exception
    {
 
-      final CountDownLatch latchAlign = new CountDownLatch(1);
-      final CountDownLatch latchStart = new CountDownLatch(1);
-
       final FakeBinding fake = new FakeBinding(new SimpleString("a"));
 
       final BindingsImpl bind = new BindingsImpl();
@@ -94,8 +91,6 @@
          {
             try
             {
-               latchAlign.countDown();
-               latchStart.await();
                bind.removeBinding(fake);
             }
             catch (Exception e)
@@ -107,16 +102,13 @@
 
       t.start();
 
-      latchAlign.await();
-      latchStart.countDown();
-
       bind.route(new FakeMessage(), new FakeTransaction());
    }
 
    public void testRemoveWhileRedistributing() throws Exception
    {
       // It would require many iterations before getting a failure
-      for (int i = 0; i < 100; i++)
+      for (int i = 0; i < 2000; i++)
       {
          internalTestRedistribute();
       }
@@ -124,10 +116,6 @@
 
    private void internalTestRedistribute() throws Exception
    {
-
-      final CountDownLatch latchAlign = new CountDownLatch(1);
-      final CountDownLatch latchStart = new CountDownLatch(1);
-
       final FakeBinding fake = new FakeBinding(new SimpleString("a"));
 
       final BindingsImpl bind = new BindingsImpl();
@@ -142,8 +130,6 @@
          {
             try
             {
-               latchAlign.countDown();
-               latchStart.await();
                bind.removeBinding(fake);
             }
             catch (Exception e)
@@ -155,9 +141,6 @@
 
       t.start();
 
-      latchAlign.await();
-      latchStart.countDown();
-
       bind.redistribute(new FakeMessage(), new SimpleString("a"), new FakeTransaction());
    }