}
public synchronized void put(SubscriptionInfo subscription) {
- allSubscriptions.put(subscription.getId(), subscription);
- subscriptionsByOwner.put(subscription.owner, subscription.id, subscription);
+ doPut(subscription);
storeInFile(subscription);
logger.debug("Added type status subscription {}", subscription.id);
}
for (File file : dbDir.listFiles()) {
String json = Files.readString(file.toPath());
SubscriptionInfo subscription = gson.fromJson(json, SubscriptionInfo.class);
- this.allSubscriptions.put(subscription.getId(), subscription);
+ doPut(subscription);
}
}
+ private void doPut(SubscriptionInfo subscription) {
+ allSubscriptions.put(subscription.getId(), subscription);
+ subscriptionsByOwner.put(subscription.owner, subscription.id, subscription);
+ }
+
private File getFile(SubscriptionInfo subscription) {
return getPath(subscription).toFile();
}