improved logging in case of exceptions during initial load

This commit is contained in:
Axel Uhl committed 2015-02-05 03:34:11 +01:00
1 parent 15dd57ee47
commit 1b048d23e0
1 file changed
+6 -1
@@ -514,7 +514,12 @@ public class ReplicationServiceImpl implements ReplicationService {
final GZIPInputStream gzipInputStream = new GZIPInputStream(rabbitInputStreamProvider.getInputStream());
for (Replicable<?, ?> replicable : getReplicables()) {
logger.info("Starting to receive initial load for "+replicable.getId());
replicable.initiallyFillFrom(gzipInputStream);
try {
replicable.initiallyFillFrom(gzipInputStream);
} catch (Exception e) {
logger.log(Level.SEVERE, "Exception trying to reveice initial load for "+replicable.getId(), e);
throw e;
}
logger.info("Done receiving initial load for "+replicable.getId());
}
logger.info("Resuming replicator to apply queues");