vertx / io.vertx.ext.cluster.infinispan / InfinispanClusterManager

InfinispanClusterManager

open class InfinispanClusterManager : ClusterManager

Author
Thomas Segismont

Constructors

<init>

InfinispanClusterManager()

Creates a new cluster manager configured with infinispan.xml and jgroups.xml files.

InfinispanClusterManager(cacheManager: DefaultCacheManager)

Creates a new cluster manager with an existing DefaultCacheManager. It is your responsibility to start/stop the cache manager when the Vert.x instance joins/leaves the cluster.

Functions

getAsyncMap

open fun <K : Any, V : Any> getAsyncMap(name: String, resultHandler: Handler<AsyncResult<AsyncMap<K, V>>>): Unit

getAsyncMultiMap

open fun <K : Any, V : Any> getAsyncMultiMap(name: String, resultHandler: Handler<AsyncResult<AsyncMultiMap<K, V>>>): Unit

getCounter

open fun getCounter(name: String, resultHandler: Handler<AsyncResult<Counter>>): Unit

getLockWithTimeout

open fun getLockWithTimeout(name: String, timeout: Long, resultHandler: Handler<AsyncResult<Lock>>): Unit

getNodeID

open fun getNodeID(): String

getNodes

open fun getNodes(): MutableList<String>

getSyncMap

open fun <K : Any, V : Any> getSyncMap(name: String): MutableMap<K, V>

isActive

open fun isActive(): Boolean

join

open fun join(resultHandler: Handler<AsyncResult<Void>>): Unit

leave

open fun leave(resultHandler: Handler<AsyncResult<Void>>): Unit

nodeListener

open fun nodeListener(nodeListener: NodeListener): Unit

setVertx

open fun setVertx(vertx: Vertx): Unit