Skip to content

Instantly share code, notes, and snippets.

@gurbuzali
Created February 26, 2015 09:08
Show Gist options
  • Save gurbuzali/da905bc34fc1c090f167 to your computer and use it in GitHub Desktop.
Save gurbuzali/da905bc34fc1c090f167 to your computer and use it in GitHub Desktop.
map-name
public class GurbuzTest {
public static void main(String[] args) {
Config config = new Config();
MapConfig mapConfig = new MapConfig();
mapConfig.setName("query.archive.*");
MapStoreConfig mapStoreConfig = new MapStoreConfig();
mapStoreConfig.setEnabled(true).setFactoryImplementation(new MyFac());
mapConfig.setMapStoreConfig(mapStoreConfig);
config.addMapConfig(mapConfig);
HazelcastInstance instance = Hazelcast.newHazelcastInstance(config);
IMap<Object, Object> map = instance.getMap("query.archive.map1");
}
static class MyFac implements MapStoreFactory {
@Override
public MapLoader newMapStore(String mapName, Properties properties) {
new Throwable("fatal newMapStore").printStackTrace();
return new MyStore(mapName);
}
}
static class MyStore implements MapStore {
final String name;
public MyStore(String name) {
this.name = name;
}
@Override
public void store(Object key, Object value) {
}
@Override
public void storeAll(Map map) {
}
@Override
public void delete(Object key) {
}
@Override
public void deleteAll(Collection keys) {
}
@Override
public Object load(Object key) {
return null;
}
@Override
public Map loadAll(Collection keys) {
return null;
}
@Override
public Set loadAllKeys() {
return null;
}
}
/*
java.lang.Throwable: newMapStore
at gurbuz.GurbuzTest$MyFac.newMapStore(GurbuzTest.java:81)
at com.hazelcast.map.impl.mapstore.StoreConstructor.getStoreFromFactoryOrNull(StoreConstructor.java:70)
at com.hazelcast.map.impl.mapstore.StoreConstructor.createStore(StoreConstructor.java:38)
at com.hazelcast.map.impl.mapstore.BasicMapStoreContext.create(BasicMapStoreContext.java:158)
at com.hazelcast.map.impl.mapstore.MapStoreContextFactory.createMapStoreContext(MapStoreContextFactory.java:50)
at com.hazelcast.map.impl.MapContainer.<init>(MapContainer.java:89)
at com.hazelcast.map.impl.DefaultMapServiceContext$1.createNew(DefaultMapServiceContext.java:38)
at com.hazelcast.map.impl.DefaultMapServiceContext$1.createNew(DefaultMapServiceContext.java:33)
at com.hazelcast.util.ConcurrencyUtil.getOrPutSynchronized(ConcurrencyUtil.java:40)
at com.hazelcast.map.impl.DefaultMapServiceContext.getMapContainer(DefaultMapServiceContext.java:76)
at com.hazelcast.map.impl.proxy.MapProxySupport.<init>(MapProxySupport.java:140)
at com.hazelcast.map.impl.proxy.MapProxyImpl.<init>(MapProxyImpl.java:75)
at com.hazelcast.map.impl.MapRemoteService.createDistributedObject(MapRemoteService.java:26)
at com.hazelcast.map.impl.MapRemoteService.createDistributedObject(MapRemoteService.java:14)
at com.hazelcast.map.impl.MapService.createDistributedObject(MapService.java:126)
at com.hazelcast.spi.impl.ProxyServiceImpl$ProxyRegistry.createProxy(ProxyServiceImpl.java:336)
at com.hazelcast.spi.impl.ProxyServiceImpl$ProxyRegistry.getOrCreateProxy(ProxyServiceImpl.java:310)
at com.hazelcast.spi.impl.ProxyServiceImpl.getDistributedObject(ProxyServiceImpl.java:131)
at com.hazelcast.instance.HazelcastInstanceImpl.getDistributedObject(HazelcastInstanceImpl.java:403)
at com.hazelcast.instance.HazelcastInstanceImpl.getMap(HazelcastInstanceImpl.java:191)
at com.hazelcast.instance.HazelcastInstanceProxy.getMap(HazelcastInstanceProxy.java:71)
*/
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment