355356357358359360361362363364365
ReplicationConsumer consumer = createConsumer(); // We should have 1000 entries plus the base entry = 1001 assertTrue( waitForSyncReplClient( consumer, 1001 ) ); consumer.stop(); System.out.println( "\n<-- Done" ); }
387388389390391392393394395396397
// Now check that the entry has been copied in the consumer assertTrue( waitForSyncReplClient( consumer, 1 ) ); // Removed the added entry providerSession.delete( addedEntry.getDn() ); consumer.stop(); System.out.println( "\n<-- Done" ); }
408409410411412413414415416417418
// Load but stop after 200 entries have been loaded waitUntilLimitSyncReplClient( 200, consumer ); // Stop the consumer consumer.stop(); // Start it again runConsumer( consumer ); // We should have 1000 entries plus the base entry = 1001
415416417418419420421422423424425
// Start it again runConsumer( consumer ); // We should have 1000 entries plus the base entry = 1001 assertTrue( waitForSyncReplClient( consumer, 1001 ) ); consumer.stop(); System.out.println( "\n<-- Done" ); }
440441442443444445446447448449
assertTrue( waitUntilLimitSyncReplClient( 1001, consumer1, consumer2, consumer3, consumer4 ) ); consumer1.stop(); consumer2.stop(); consumer3.stop(); consumer4.stop(); System.out.println( "\n<-- Done" ); } }