Skip to content

Commit 78e48e2

Browse files
georgeajitgeorgeajit
authored andcommitted
No Task - Removed Comman.java dependency and pulled in changes from
develop that got removed.
1 parent 486ab3e commit 78e48e2

File tree

3 files changed

+53
-164
lines changed

3 files changed

+53
-164
lines changed

marklogic-client-api-functionaltests/src/test/java/com/marklogic/client/datamovement/functionaltests/ExportListenerTest.java

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,7 @@ public void testPointInTimeQueryDeterministicSet() throws Exception {
229229
*/
230230
@Test
231231
public void testWithSnapshots() throws Exception {
232-
System.out.println("Running testPointInTimeQueryDeterministicSet");
232+
System.out.println("Running testWithSnapshots");
233233
Map<String, String> props = new HashMap<String, String>();
234234
props.put("merge-timestamp", "-6000000000");
235235
changeProperty(props, "/manage/v2/databases/" + dbName + "/properties");
@@ -251,6 +251,7 @@ public void testWithSnapshots() throws Exception {
251251
.onDocumentReady(doc -> {
252252
String uriOfDoc = doc.getUri();
253253
// Make sure the docs are available. Not deleted from DB.
254+
System.out.println("Document exported is " + uriOfDoc);
254255
docExporterList.add(uriOfDoc);
255256
}
256257
);
@@ -263,7 +264,7 @@ public void testWithSnapshots() throws Exception {
263264
if (batch.getJobBatchNumber() == 1) {
264265
// Verifying getServerTimestamp with withConsistentSnapshot - Git
265266
// Issue 629.
266-
System.out.println("Server Time from Batch 1 is " + batch.getServerTimestamp());
267+
System.out.println("Server Time from Batch 1 in exportBatcher is " + batch.getServerTimestamp());
267268
assertTrue("Server Timestamp incorrect", batch.getServerTimestamp() > 0);
268269
}
269270
for (String u : batch.getItems()) {
@@ -299,6 +300,13 @@ public void testWithSnapshots() throws Exception {
299300
QueryBatcher deleteBatcher = dmManager.newQueryBatcher(querydef)
300301
.withConsistentSnapshot()
301302
.withBatchSize(100)
303+
.onUrisReady(batch -> {
304+
if (batch.getJobBatchNumber() == 1) {
305+
System.out.println("Server Time from Batch 1 in deleteBatcher is " + batch.getServerTimestamp());
306+
assertTrue("Server Timestamp incorrect", batch.getServerTimestamp() > 0);
307+
}
308+
}
309+
)
302310
.onUrisReady(new DeleteListener());
303311

304312
dmManager.startJob(deleteBatcher);

0 commit comments

Comments
 (0)