- synchronized (snapshotList) {
- Iterator<StoredSnapshot> iter = snapshotList.iterator();
- while(iter.hasNext()) {
- StoredSnapshot s = iter.next();
- if(matches(s, snapshotSelectionCriteria)) {
- LOG.trace("Deleting snapshot for sequenceNr: {}, timestamp: {}",
- s.metadata.sequenceNr(), s.metadata.timestamp());
-
- iter.remove();
+ List<StoredSnapshot> snapshotList = snapshots.get(persistenceId);
+ if (snapshotList != null) {
+ synchronized (snapshotList) {
+ Iterator<StoredSnapshot> iter = snapshotList.iterator();
+ while (iter.hasNext()) {
+ StoredSnapshot stored = iter.next();
+ if (matches(stored, criteria)) {
+ LOG.trace("Deleting snapshot for sequenceNr: {}, timestamp: {}: {}",
+ stored.metadata.sequenceNr(), stored.metadata.timestamp(), stored.data);
+
+ iter.remove();
+ }