From 30c50acf67be34fe6bd74f4a3eb2cc2851d34500 Mon Sep 17 00:00:00 2001 From: chenson42 Date: Wed, 21 May 2008 01:09:14 +0000 Subject: [PATCH] also include filter milliseconds --- .../org/jumpmind/symmetric/service/impl/DataLoaderService.java | 3 +++ 1 file changed, 3 insertions(+) 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 index 6fd19c6cd5..986abb6d25 100644 --- a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java +++ b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java @@ -283,9 +283,12 @@ public void doInTransactionWithoutResult(TransactionStatus transactionstatus) { private void fireBatchComplete(IDataLoader loader, IncomingBatchHistory history) { if (batchListeners != null) { + long ts = System.currentTimeMillis(); for (IBatchListener listener : batchListeners) { listener.batchComplete(loader, history); } + // update the filter milliseconds so batch listeners are also included + history.setFilterMillis(history.getFilterMillis() + (System.currentTimeMillis()-ts)); } }