#826 - Fixed for failed batches as well

vivekmuniyandi · vivekmuniyandi · commit 2aa19286351c · 2017-10-12T13:21:56.000-07:00
diff --git a/src/main/java/com/marklogic/client/datamovement/impl/WriteBatcherImpl.java b/src/main/java/com/marklogic/client/datamovement/impl/WriteBatcherImpl.java
@@ -622,6 +622,7 @@ private void sendThrowableToListeners(Throwable t, String message, Collection<Ba
   }
 
   private void sendThrowableToListeners(Throwable t, String message, BatchWriteSet batchWriteSet) {
+    batchWriteSet.setItemsSoFar(itemsSoFar.get());
     WriteBatch batch = batchWriteSet.getBatchOfWriteEvents();
     for ( WriteFailureListener failureListener : failureListeners ) {
       try {

Original file line number	Diff line number	Diff line change
`@@ -622,6 +622,7 @@ private void sendThrowableToListeners(Throwable t, String message, Collection<Ba`
`622`	`622`	`}`
`623`	`623`
`624`	`624`	`private void sendThrowableToListeners(Throwable t, String message, BatchWriteSet batchWriteSet) {`
	`625`	`+ batchWriteSet.setItemsSoFar(itemsSoFar.get());`
`625`	`626`	`WriteBatch batch = batchWriteSet.getBatchOfWriteEvents();`
`626`	`627`	`for ( WriteFailureListener failureListener : failureListeners ) {`
`627`	`628`	`try {`