public class HazelcastClusterManager extends Object implements io.vertx.core.impl.ExtendedClusterManager, MembershipListener
Constructor and Description |
---|
HazelcastClusterManager()
Constructor - gets config from classpath
|
HazelcastClusterManager(Config conf)
Constructor - config supplied
|
HazelcastClusterManager(HazelcastInstance instance) |
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.
|
Config |
getConfig()
Get the Hazelcast config
|
void |
getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler) |
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
|
Config |
loadConfig() |
void |
memberAdded(MembershipEvent membershipEvent) |
void |
memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) |
void |
memberRemoved(MembershipEvent membershipEvent) |
void |
nodeListener(NodeListener listener)
Set a listener that will be called when a node joins or leaves the cluster.
|
void |
setConfig(Config config)
Set the hazelcast config
|
void |
setVertx(Vertx vertx) |
public HazelcastClusterManager()
public HazelcastClusterManager(Config conf)
conf
- public HazelcastClusterManager(HazelcastInstance instance)
public void setVertx(Vertx vertx)
setVertx
in interface ClusterManager
public void join(Handler<AsyncResult<Void>> resultHandler)
ClusterManager
join
in interface ClusterManager
public <K,V> void getAsyncMultiMap(String name, Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
getAsyncMultiMap
in interface ClusterManager
name
- 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.resultHandler
- handler receiving the multimappublic String getNodeID()
ClusterManager
getNodeID
in interface ClusterManager
public List<String> getNodes()
ClusterManager
getNodes
in interface ClusterManager
public void nodeListener(NodeListener listener)
ClusterManager
nodeListener
in interface ClusterManager
public <K,V> void getAsyncMap(String name, Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
ClusterManager
getAsyncMap
in interface ClusterManager
public <K,V> Map<K,V> getSyncMap(String name)
ClusterManager
getSyncMap
in interface ClusterManager
public void getLockWithTimeout(String name, long timeout, Handler<AsyncResult<Lock>> resultHandler)
getLockWithTimeout
in interface ClusterManager
public void getCounter(String name, Handler<AsyncResult<Counter>> resultHandler)
getCounter
in interface ClusterManager
public void leave(Handler<AsyncResult<Void>> resultHandler)
ClusterManager
leave
in interface ClusterManager
public void memberAdded(MembershipEvent membershipEvent)
memberAdded
in interface MembershipListener
public void memberRemoved(MembershipEvent membershipEvent)
memberRemoved
in interface MembershipListener
public boolean isActive()
ClusterManager
isActive
in interface ClusterManager
public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent)
memberAttributeChanged
in interface MembershipListener
public Config getConfig()
public void setConfig(Config config)
config
- public Config loadConfig()
public void beforeLeave()
beforeLeave
in interface io.vertx.core.impl.ExtendedClusterManager
public HazelcastInstance getHazelcastInstance()
Copyright © 2016. All rights reserved.