Skip to content

Commit 62ae3e3

Browse files
author
ehennum
committed
internal CallBatcher uses DataMovementManagerImpl #1109
1 parent f7384e9 commit 62ae3e3

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/impl/DataMovementManagerImpl.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,6 @@ public void release() {
8282
}
8383
}
8484

85-
@Override
8685
public JobTicket startJob(CallBatcher batcher) {
8786
if ( batcher == null ) throw new IllegalArgumentException("batcher must not be null");
8887
return service.startJob(batcher, activeJobs);

marklogic-client-api/src/main/java/com/marklogic/client/dataservices/impl/CallBatcherImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import com.marklogic.client.datamovement.*;
2121
import com.marklogic.client.datamovement.impl.BatchEventImpl;
2222
import com.marklogic.client.datamovement.impl.BatcherImpl;
23+
import com.marklogic.client.datamovement.impl.DataMovementManagerImpl;
2324
import com.marklogic.client.dataservices.impl.CallManager.CallArgs;
2425
import com.marklogic.client.dataservices.impl.CallManagerImpl.CallArgsImpl;
2526

@@ -423,7 +424,7 @@ private void flush(boolean waitForCompletion) {
423424
}
424425

425426
@Override
426-
public DataMovementManager getDataMovementManager() {
427+
public DataMovementManagerImpl getDataMovementManager() {
427428
return super.getMoveMgr();
428429
}
429430

0 commit comments

Comments
 (0)