ClusteredDataFactory.java

package zencode.hazelcast;

import com.hazelcast.core.IMap;

import javax.inject.Inject;

/**
 * Factory for clustered replicated data.
 * @author Koert Zeilstra
 */
public class ClusteredDataFactory {

    @Inject private HazelcastFactory hazelcastFactory;

    /**
     * Retrieve (or create) map.
     * @param name Map name
     * @param <KeyType> Key type.
     * @param <ValueType> Value type.
     * @return Clustered map.
     */
    public <KeyType, ValueType> ClusteredMap<KeyType, ValueType> getMap(String name) {
        IMap<KeyType, ValueType> map = hazelcastFactory.getInstance().getMap(name);
        return new ClusteredMap<>(map);
    }

}