[jboss-cvs] JBoss Messaging SVN: r3072 - in trunk: tests and 1 other directories.

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

Author: clebert.suconic at jboss.com
Date: 2007-08-29 12:13:14 -0400 (Wed, 29 Aug 2007)
New Revision: 3072

Modified:
   trunk/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java
   trunk/tests/build.xml
   trunk/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPostOfficeTest.java
Log:
http://jira.jboss.com/jira/browse/JBMESSAGING-1061 - fix

Modified: trunk/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2007-08-29 15:06:53 UTC (rev 3071)
+++ trunk/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2007-08-29 16:13:14 UTC (rev 3072)
@@ -212,7 +212,10 @@
    	
    	dataChannel = null;   	   	
    	
-   	currentView = null;   	
+   	currentView = null;
+
+      // Workaround for JGroups
+      Thread.sleep(1000);
    }
    
    public Address getSyncAddress()

Modified: trunk/tests/build.xml
===================================================================
--- trunk/tests/build.xml	2007-08-29 15:06:53 UTC (rev 3071)
+++ trunk/tests/build.xml	2007-08-29 16:13:14 UTC (rev 3072)
@@ -351,8 +351,6 @@
                <exclude name="**/jms/bridge/**"/>
                <exclude name="**/jms/manual/**"/>
                <exclude name="**/jms/clustering/**"/>
-               <exclude name="**/ClusteredPostOfficeTest.class"/> <!-- Remove temporarily -->  
-
             </fileset>
          </batchtest>
       </junit>
@@ -470,8 +468,6 @@
                <exclude name="**/jms/ManifestTest.class"/>
                <exclude name="**/jms/JCAWrapperTest.class"/>
                <exclude name="**/jms/ClientExitTest.class"/>
-               <exclude name="**/ClusteredPostOfficeTest.class"/> <!-- Remove temporarily -->  
-
             </fileset>
          </batchtest>
       </junit>

Modified: trunk/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPostOfficeTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPostOfficeTest.java	2007-08-29 15:06:53 UTC (rev 3071)
+++ trunk/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPostOfficeTest.java	2007-08-29 16:13:14 UTC (rev 3072)
@@ -1513,7 +1513,11 @@
    	{
    		if (office1 != null)
    		{
-   			office1.stop();
+            office1.removeBinding("queue1", true);
+            office1.removeBinding("queue2", true);
+            office1.removeBinding("queue3", true);
+            office1.removeBinding("queue4", true);
+            office1.stop();
    		}
    	}
    }
@@ -2002,7 +2006,7 @@
    		assertNotNull(msgs);
    		assertEquals(1, msgs.size());
    		Message msgRec = (Message)msgs.get(0);
-   		assertTrue(msg2 == msgRec);
+   		assertEquals(msg2, msgRec);
    		receiver1.acknowledge(msgRec, null);
    		msgs = queue1.browse(null);
    		assertNotNull(msgs);
@@ -2012,7 +2016,7 @@
    		assertNotNull(msgs);
    		assertEquals(1, msgs.size());
    		msgRec = (Message)msgs.get(0);
-   		assertTrue(msg3 == msgRec);
+   		assertEquals(msg3, msgRec);
    		receiver2.acknowledge(msgRec, null);
    		msgs = queue2.browse(null);
    		assertNotNull(msgs);
@@ -2022,11 +2026,11 @@
    		assertNotNull(msgs);
    		assertEquals(3, msgs.size());
    		Message msgRec1 = (Message)msgs.get(0);
-   		assertTrue(msg1 == msgRec1);
+   		assertEquals(msg1, msgRec1);
    		Message msgRec2 = (Message)msgs.get(1);
-   		assertTrue(msg2 == msgRec2);
+   		assertEquals(msg2, msgRec2);
    		Message msgRec3 = (Message)msgs.get(2);
-   		assertTrue(msg3 == msgRec3);
+   		assertEquals(msg3, msgRec3);
 
    		receiver3.acknowledge(msgRec1, null);
    		receiver3.acknowledge(msgRec2, null);
@@ -2120,11 +2124,11 @@
    		assertNotNull(msgs);
    		assertEquals(3, msgs.size());
    		Message msgRec1 = (Message)msgs.get(0);
-   		assertTrue(msg1 == msgRec1);
+   		assertEquals(msg1,  msgRec1);
    		Message msgRec2 = (Message)msgs.get(1);
-   		assertTrue(msg2 == msgRec2);
+   		assertEquals(msg2, msgRec2);
    		Message msgRec3 = (Message)msgs.get(2);
-   		assertTrue(msg3 == msgRec3);
+   		assertEquals(msg3, msgRec3);
 
    		receiver1.acknowledge(msgRec1, null);
    		receiver1.acknowledge(msgRec2, null);
@@ -2137,11 +2141,11 @@
    		assertNotNull(msgs);
    		assertEquals(3, msgs.size());
    		msgRec1 = (Message)msgs.get(0);
-   		assertTrue(msg1 == msgRec1);
+   		assertEquals(msg1, msgRec1);
    		msgRec2 = (Message)msgs.get(1);
-   		assertTrue(msg2 == msgRec2);
+   		assertEquals(msg2, msgRec2);
    		msgRec3 = (Message)msgs.get(2);
-   		assertTrue(msg3 == msgRec3);
+   		assertEquals(msg3, msgRec3);
 
    		receiver2.acknowledge(msgRec1, null);
    		receiver2.acknowledge(msgRec2, null);
@@ -2154,11 +2158,11 @@
    		assertNotNull(msgs);
    		assertEquals(3, msgs.size());
    		msgRec1 = (Message)msgs.get(0);
-   		assertTrue(msg1 == msgRec1);
+   		assertEquals(msg1, msgRec1);
    		msgRec2 = (Message)msgs.get(1);
-   		assertTrue(msg2 == msgRec2);
+   		assertEquals(msg2, msgRec2);
    		msgRec3 = (Message)msgs.get(2);
-   		assertTrue(msg3 == msgRec3);
+   		assertEquals(msg3, msgRec3);
 
    		receiver3.acknowledge(msgRec1, null);
    		receiver3.acknowledge(msgRec2, null);
@@ -2171,11 +2175,11 @@
    		assertNotNull(msgs);
    		assertEquals(3, msgs.size());
    		msgRec1 = (Message)msgs.get(0);
-   		assertTrue(msg1 == msgRec1);
+   		assertEquals(msg1, msgRec1);
    		msgRec2 = (Message)msgs.get(1);
-   		assertTrue(msg2 == msgRec2);
+   		assertEquals(msg2, msgRec2);
    		msgRec3 = (Message)msgs.get(2);
-   		assertTrue(msg3 == msgRec3);
+   		assertEquals(msg3, msgRec3);
 
    		receiver4.acknowledge(msgRec1, null);
    		receiver4.acknowledge(msgRec2, null);