diff --git a/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/repository/invalidation/DeferredInvalidationQueueService.java b/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/repository/invalidation/DeferredInvalidationQueueService.java index 0a1bd7f8..8ed1a727 100644 --- a/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/repository/invalidation/DeferredInvalidationQueueService.java +++ b/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/repository/invalidation/DeferredInvalidationQueueService.java @@ -36,7 +36,11 @@ public class DeferredInvalidationQueueService implements PeerConnectedEventListe Log.info("Initializing with root " + dataRoot); if (Paths.get(dataRoot).resolve(dataFileName).toFile().exists()) { Log.info("Reading invalidation queue"); - _persistentData = SerializationHelper.deserialize(Files.readAllBytes(Paths.get(dataRoot).resolve(dataFileName))); + try { + _persistentData = SerializationHelper.deserialize(Files.readAllBytes(Paths.get(dataRoot).resolve(dataFileName))); + } catch (Exception e) { + Log.error("Error reading invalidation queue", e); + } } }