public synchronized Store open()

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;
	}