in src/main/java/org/apache/servicemix/store/krati/KratiStoreFactory.java [49:83]
public synchronized Store open(String name) throws IOException {
KratiStore store = stores.get(name);
if (store == null) {
DataStore<byte[], byte[]> dataStore = null;
try {
String storeName = STORE_PREFIX + "." + name;
StringBuilder sb = new StringBuilder(storeDirectory);
sb.append("/");
File storeFolder = new File(sb.toString());
storeFolder.mkdir();
File file = new File(storeFolder,name);
StoreConfig config = new StoreConfig(file, initCapacity);
config.setSegmentFactory(new MemorySegmentFactory());
config.setSegmentFileSizeMB(Segment.minSegmentFileSizeMB);
dataStore = StoreFactory.createDynamicDataStore(config);
if (timeout <= 0) {
store = new KratiStore(dataStore);
} else {
store = new KratiStore(dataStore, timeout);
}
stores.put(name, store);
for (StoreListener listener : storeListeners) {
store.addListener(listener);
}
} catch (Exception e) {
LOG.error("Error during store initialization, {}", e, e);
}
}
return store;
}