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