public class HazelcastClusterManager extends Object implements io.vertx.core.impl.ExtendedClusterManager, com.hazelcast.core.MembershipListener
| Constructor and Description |
|---|
HazelcastClusterManager()
Constructor - gets config from classpath
|
HazelcastClusterManager(com.hazelcast.config.Config conf)
Constructor - config supplied
|
| Modifier and Type | Method and Description |
|---|---|
void |
beforeLeave() |
<K,V> void |
getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Return an async map for the given name
|
<K,V> void |
getAsyncMultiMap(String name,
Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
Every eventbus handler has an ID.
|
com.hazelcast.config.Config |
getConfig()
Get the Hazelcast config
|
void |
getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler) |
com.hazelcast.core.HazelcastInstance |
getHazelcastInstance() |
void |
getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler) |
String |
getNodeID()
Return the unique node ID for this node
|
List<String> |
getNodes()
Return a list of node IDs corresponding to the nodes in the cluster
|
<K,V> Map<K,V> |
getSyncMap(String name)
Return a synchronous map for the given name
|
boolean |
isActive()
Is the cluster manager active?
|
void |
join(Handler<AsyncResult<Void>> resultHandler)
Join the cluster
|
void |
leave(Handler<AsyncResult<Void>> resultHandler)
Leave the cluster
|
com.hazelcast.config.Config |
loadConfigFromClasspath() |
void |
memberAdded(com.hazelcast.core.MembershipEvent membershipEvent) |
void |
memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent) |
void |
memberRemoved(com.hazelcast.core.MembershipEvent membershipEvent) |
void |
nodeListener(NodeListener listener)
Set a listener that will be called when a node joins or leaves the cluster.
|
void |
setConfig(com.hazelcast.config.Config config)
Set the hazelcast config
|
void |
setVertx(Vertx vertx) |
public HazelcastClusterManager()
public HazelcastClusterManager(com.hazelcast.config.Config conf)
conf - public void setVertx(Vertx vertx)
setVertx in interface ClusterManagerpublic void join(Handler<AsyncResult<Void>> resultHandler)
ClusterManagerjoin in interface ClusterManagerpublic <K,V> void getAsyncMultiMap(String name, Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
getAsyncMultiMap in interface ClusterManagername - A unique name by which the the MultiMap can be identified within the cluster.
See the cluster config file (e.g. cluster.xml in case of HazelcastClusterManager) for
additional MultiMap config parameters.public String getNodeID()
ClusterManagergetNodeID in interface ClusterManagerpublic List<String> getNodes()
ClusterManagergetNodes in interface ClusterManagerpublic void nodeListener(NodeListener listener)
ClusterManagernodeListener in interface ClusterManagerpublic <K,V> void getAsyncMap(String name, Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
ClusterManagergetAsyncMap in interface ClusterManagerpublic <K,V> Map<K,V> getSyncMap(String name)
ClusterManagergetSyncMap in interface ClusterManagerpublic void getLockWithTimeout(String name, long timeout, Handler<AsyncResult<Lock>> resultHandler)
getLockWithTimeout in interface ClusterManagerpublic void getCounter(String name, Handler<AsyncResult<Counter>> resultHandler)
getCounter in interface ClusterManagerpublic void leave(Handler<AsyncResult<Void>> resultHandler)
ClusterManagerleave in interface ClusterManagerpublic void memberAdded(com.hazelcast.core.MembershipEvent membershipEvent)
memberAdded in interface com.hazelcast.core.MembershipListenerpublic void memberRemoved(com.hazelcast.core.MembershipEvent membershipEvent)
memberRemoved in interface com.hazelcast.core.MembershipListenerpublic boolean isActive()
ClusterManagerisActive in interface ClusterManagerpublic void memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent)
memberAttributeChanged in interface com.hazelcast.core.MembershipListenerpublic com.hazelcast.config.Config getConfig()
public void setConfig(com.hazelcast.config.Config config)
config - public com.hazelcast.config.Config loadConfigFromClasspath()
public void beforeLeave()
beforeLeave in interface io.vertx.core.impl.ExtendedClusterManagerpublic com.hazelcast.core.HazelcastInstance getHazelcastInstance()
Copyright © 2015. All rights reserved.