The loadDataBatch() needs to make callbacks to the IBatchListener

JumpMind · Sep 23, 2008 · 4f28f7c · 4f28f7c
1 parent 5f3a2e0
commit 4f28f7c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
@@ -168,6 +168,9 @@ public IDataLoaderStatistics loadDataBatch(String batchData) throws IOException
         try {
             while (dataLoader.hasNext()) {
                 dataLoader.load();
+                IncomingBatchHistory history = new IncomingBatchHistory(dataLoader.getContext());
+                history.setValues(dataLoader.getStatistics(), true);
+                fireBatchComplete(dataLoader, history);                
             }
         } finally {
             stats = dataLoader.getStatistics();