Reader.java revision ef6648a7917a74b386ded70f1d799becd7b74386
0N/A * The contents of this file are subject to the terms of the 0N/A * Common Development and Distribution License, Version 1.0 only 0N/A * (the "License"). You may not use this file except in compliance 0N/A * You can obtain a copy of the license at 0N/A * See the License for the specific language governing permissions 0N/A * and limitations under the License. 2362N/A * When distributing Covered Code, include this CDDL HEADER in each 0N/A * file and include the License file at 0N/A * add the following below this CDDL HEADER, with the fields enclosed 0N/A * by brackets "[]" replaced with your own identifying information: 0N/A * Portions Copyright [yyyy] [name of copyright owner] 0N/A * Copyright 2010 Sun Microsystems, Inc. // master number in the array list // ECL "draft" mode index // ECL "opends" mode index // Connect to the Directory master // Try to retrieve the ECL index (changenumber|changelogcookie) of the last update read // ---> use the CSN stored in the file under "db" directory String filter =
"(& (objectclass=changelogentry)(replicationCSN=" new String[] {
"changeNumber",
"changeLogCookie"} ,
new String[]{
"firstChangeNumber"} ,
false );
}
/* for (CSN csn: ...) */ "targetEntryUUID",
"changeType",
"changes",
"deleteOldRDN",
"newRDN",
"newSuperior",
"changeNumber",
"changeHasReplFixupOp",
// --control "1.3.6.1.4.1.26027.1.5.4:false:;" // No new change found in retrocl => sleep 100 ms. // Forward all the results found to the application //EclReadAndPlay.println("DEBUG", "Changelog entry: " + entry.toString()); // Write the change in the queue }
/* while (result.hasMoreElements()) */ new String[]{
"lastChangeNumber"} ,
false );
new String[]{
"lastExternalChangelogCookie"} ,
false );
}
/* while (idleTime <= EclReadAndPlay.MAX_IDLE_TIME) */ " milliseconds. ======> EXIT");
// if server is down => switch // clear the queue of changes