svn commit: r1151438 - /directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java

[ka...@apache.org]

Author: kayyagari
Date: Wed Jul 27 12:08:44 2011
New Revision: 1151438

URL: http://svn.apache.org/viewvc?rev=1151438&view=rev
Log:
o fixed the failing test(it is all due to timing), removed @Ignore

Modified:
    directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java

Modified: directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java
URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java?rev=1151438&r1=1151437&r2=1151438&view=diff
==============================================================================
--- directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java (original)
+++ directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java Wed Jul 27 12:08:44 2011
@@ -55,7 +55,6 @@ import org.apache.directory.shared.ldap.
 import org.apache.directory.shared.ldap.model.schema.SchemaManager;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
-import org.junit.Ignore;
 import org.junit.Test;
 
 /**
@@ -240,7 +239,6 @@ public class ClientServerReplicationIT
     
     
     @Test
-    @Ignore( "test is failing" )
     public void testRebootConsumer() throws Exception
     {
         System.out.println( "----> 1 testRebootConsumer started --------------------------------" );
@@ -275,6 +273,11 @@ public class ClientServerReplicationIT
         System.out.println( "----> 6 adding entry " + provUser.getDn() + " into provider --------------------------------" );
         providerSession.add( provUser );
         
+        // let the provider log the events before the consumer sends a request
+        // we are dealing with fraction of seconds cause of the programmatic simulation
+        // it is impossible in the real world scenario
+        Thread.sleep( 1000 );
+        
         // Restart the consumer
         System.out.println( "----> 7 Restarting the consumer --------------------------------" );
         consumerServer.start();