422423424425426427428429430431432
// 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" ); }
447448449450451452453454455456
assertTrue( waitUntilLimitSyncReplClient( 1001, consumer1, consumer2, consumer3, consumer4 ) ); consumer1.stop(); consumer2.stop(); consumer3.stop(); consumer4.stop(); System.out.println( "\n<-- Done" ); } }
359360361362363364365366367368369
ReplicationConsumer consumer = createConsumer(); // We should have 1000 entries plus the base entry = TOTAL_COUNT assertTrue( waitForSyncReplClient( consumer, TOTAL_COUNT ) ); consumer.stop(); System.out.println( "\n<-- Done" ); }
391392393394395396397398399400401
// 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" ); }
412413414415416417418419420421422
// Load all the entries waitUntilLimitSyncReplClient( TOTAL_COUNT, consumer ); // Stop the consumer consumer.stop(); int additionalCount = 10; List<Dn> newEntries = new ArrayList<Dn>(); for( int i = 0; i < additionalCount; i++ ) {
429430431432433434435436437438439
// Start it again runConsumer( consumer ); // We should get only the additional values cause consumer sends a cookie now assertTrue( waitForSyncReplClient( consumer, additionalCount ) ); consumer.stop(); for( Dn dn : newEntries ) { providerSession.delete( dn ); }
458459460461462463464465466467
assertTrue( waitUntilLimitSyncReplClient( TOTAL_COUNT, consumer1, consumer2, consumer3, consumer4 ) ); consumer1.stop(); consumer2.stop(); consumer3.stop(); consumer4.stop(); System.out.println( "\n<-- Done" ); } }