diff --git a/api/src/main/java/org/open4goods/api/services/store/DataFragmentStoreService.java b/api/src/main/java/org/open4goods/api/services/store/DataFragmentStoreService.java index 52194f757..66471c317 100644 --- a/api/src/main/java/org/open4goods/api/services/store/DataFragmentStoreService.java +++ b/api/src/main/java/org/open4goods/api/services/store/DataFragmentStoreService.java @@ -205,7 +205,7 @@ public void aggregateAndstore(Collection buffer) { aggregatedDataRepository.index(results); - logger.info("Indexed {} DataFragments", buffer.size(),System.currentTimeMillis()); + logger.info("Indexed {} DataFragments. Queue size is {}", buffer.size(),queue.size()); } catch (final Exception e) { logger.error("Error while dequeing DataFragments",e);