io.vertx.quiz.fakecluster

Class FakeClusterManager

java.lang.Object

io.vertx.quiz.fakecluster.FakeClusterManager

All Implemented Interfaces:

io.vertx.core.spi.cluster.ClusterManager

public class FakeClusterManager
extends Object
implements io.vertx.core.spi.cluster.ClusterManager

Constructor Summary

Constructors

Constructor and Description
FakeClusterManager()

Method Summary

Modifier and Type	Method and Description
<K,V> void	getAsyncMap(String name, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.AsyncMap<K,V>>> resultHandler)
<K,V> void	getAsyncMultiMap(String name, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.spi.cluster.AsyncMultiMap<K,V>>> resultHandler)
void	getCounter(String name, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Counter>> resultHandler)
void	getLockWithTimeout(String name, long timeout, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Lock>> resultHandler)
String	getNodeID()
List<String>	getNodes()
<K,V> Map<K,V>	getSyncMap(String name)
boolean	isActive()
void	join(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
void	leave(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
void	nodeListener(io.vertx.core.spi.cluster.NodeListener listener)
static void	reset()
void	setVertx(io.vertx.core.Vertx vertx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FakeClusterManager

public FakeClusterManager()

Method Detail

setVertx

public void setVertx(io.vertx.core.Vertx vertx)

Specified by:

setVertx in interface io.vertx.core.spi.cluster.ClusterManager

getAsyncMultiMap

public <K,V> void getAsyncMultiMap(String name,
                                   io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.spi.cluster.AsyncMultiMap<K,V>>> resultHandler)

Specified by:

getAsyncMultiMap in interface io.vertx.core.spi.cluster.ClusterManager

getAsyncMap

public <K,V> void getAsyncMap(String name,
                              io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.AsyncMap<K,V>>> resultHandler)

Specified by:

getAsyncMap in interface io.vertx.core.spi.cluster.ClusterManager

getSyncMap

public <K,V> Map<K,V> getSyncMap(String name)

Specified by:

getSyncMap in interface io.vertx.core.spi.cluster.ClusterManager

getLockWithTimeout

public void getLockWithTimeout(String name,
                               long timeout,
                               io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Lock>> resultHandler)

Specified by:

getLockWithTimeout in interface io.vertx.core.spi.cluster.ClusterManager

getCounter

public void getCounter(String name,
                       io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Counter>> resultHandler)

Specified by:

getCounter in interface io.vertx.core.spi.cluster.ClusterManager

getNodeID

public String getNodeID()

Specified by:

getNodeID in interface io.vertx.core.spi.cluster.ClusterManager

getNodes

public List<String> getNodes()

Specified by:

getNodes in interface io.vertx.core.spi.cluster.ClusterManager

nodeListener

public void nodeListener(io.vertx.core.spi.cluster.NodeListener listener)

Specified by:

nodeListener in interface io.vertx.core.spi.cluster.ClusterManager

join

public void join(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)

Specified by:

join in interface io.vertx.core.spi.cluster.ClusterManager

leave

public void leave(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)

Specified by:

leave in interface io.vertx.core.spi.cluster.ClusterManager

isActive

public boolean isActive()

Specified by:

isActive in interface io.vertx.core.spi.cluster.ClusterManager

reset

public static void reset()