public synchronized Store open()

in src/main/java/org/apache/servicemix/store/hazelcast/HazelcastStoreFactory.java [44:65]


    public synchronized Store open(String name) throws IOException {
        if (hazelcastInstance == null) {
            hazelcastInstance = Hazelcast.newHazelcastInstance(null);
        }
        stores = hazelcastInstance.getMap(STORE_PREFIX);
        HazelcastStore store = stores.get(name);
        String storeName = STORE_PREFIX + "." + name;
        if (store == null) {
            IdGenerator idGenerator = hazelcastInstance.getIdGenerator(storeName);
            if (timeout <= 0) {
                store = new HazelcastStore(hazelcastInstance, storeName);
            } else {
                store = new HazelcastStore(hazelcastInstance, storeName, timeout);
            }

            for(StoreListener listener:storeListeners) {
                store.addListener(listener);
            }
            stores.put(name, store);
        }
        return store;
    }