@Test public void testDistributedMap() throws Exception { try { cluster.distributedMap("map"); fail("Expecting this to fail"); } catch (NullPointerException e) { verify(cluster, times(1)).guardAgainstInitializationFailures(); } }
public <K, V> IMap<K, V> distributedMap(String name) { guardAgainstInitializationFailures(); return hazelcast.getMap(name); }
Cluster { public <K, V> IMap<K, V> distributedMap(String name) { guardAgainstInitializationFailures(); return hazelcast.getMap(name); } }
Cluster { public <K, V> IMap<K, V> distributedMap(String name) { guardAgainstInitializationFailures(); return hazelcast.getMap(name); } @Inject  Cluster(AppConfig appConfig, ShutdownHook shutdownHook); }
Cluster { public <K, V> IMap<K, V> distributedMap(String name) { guardAgainstInitializationFailures(); return hazelcast.getMap(name); } @Inject  Cluster(AppConfig appConfig, ShutdownHook shutdownHook); void registerListener(MembershipListener membershipListener); void registerListener(MigrationListener clusterMigrationListener); IMap<K, V> distributedMap(String name); boolean isMaster(); boolean isEnabled(); }
Cluster { public <K, V> IMap<K, V> distributedMap(String name) { guardAgainstInitializationFailures(); return hazelcast.getMap(name); } @Inject  Cluster(AppConfig appConfig, ShutdownHook shutdownHook); void registerListener(MembershipListener membershipListener); void registerListener(MigrationListener clusterMigrationListener); IMap<K, V> distributedMap(String name); boolean isMaster(); boolean isEnabled();  }