open class HazelcastClusterManager : ClusterManager, MembershipListener, LifecycleListener
A cluster manager that uses Hazelcast
Author
Tim Fox
HazelcastClusterManager()
Constructor - gets config from classpath HazelcastClusterManager(conf: Config)
Constructor - config supplied HazelcastClusterManager(instance: HazelcastInstance) |
open fun <K : Any, V : Any> getAsyncMap(: String, : Handler<AsyncResult<AsyncMap<K, V>>>): Unit |
|
open fun <K : Any, V : Any> getAsyncMultiMap(name: String, resultHandler: Handler<AsyncResult<AsyncMultiMap<K, V>>>): Unit
Every eventbus handler has an ID. SubsMap (subscriber map) is a MultiMap which maps handler-IDs with server-IDs and thus allows the eventbus to determine where to send messages. |
|
open fun getConfig(): Config
Get the Hazelcast config. |
|
open fun getCounter(: String, : Handler<AsyncResult<Counter>>): Unit |
|
open fun getHazelcastInstance(): HazelcastInstance |
|
open fun getLockWithTimeout(: String, : Long, : Handler<AsyncResult<Lock>>): Unit |
|
open fun getNodeID(): String |
|
open fun getNodes(): MutableList<String> |
|
open fun <K : Any, V : Any> getSyncMap(name: String): MutableMap<K, V> |
|
open fun isActive(): Boolean |
|
open fun join(resultHandler: Handler<AsyncResult<Void>>): Unit |
|
open fun leave(resultHandler: Handler<AsyncResult<Void>>): Unit |
|
open fun loadConfig(): Config
Load Hazelcast config XML and transform it into a Config object. The content is read from:
The cluster manager uses this method to load the config when the node joins the cluster, if no config was provided upon creation. You may use this method to get a base config and customize it before the node joins the cluster. In this case, don't forget to invoke |
|
open fun memberAdded(membershipEvent: MembershipEvent): Unit |
|
open fun memberAttributeChanged(memberAttributeEvent: MemberAttributeEvent): Unit |
|
open fun memberRemoved(membershipEvent: MembershipEvent): Unit |
|
open fun nodeListener(listener: NodeListener): Unit |
|
open fun setConfig(config: Config): Unit
Set the Hazelcast config. |
|
open fun setVertx(vertx: Vertx): Unit |
|
open fun stateChanged(lifecycleEvent: LifecycleEvent): Unit |