public class SharedData extends Object
Shared data provides:
Please see the documentation for more information.
NOTE: This class has been automatically generated from theoriginal non RX-ified interface using Vert.x codegen.| Constructor and Description |
|---|
SharedData(SharedData delegate) |
public SharedData(SharedData delegate)
public Object getDelegate()
public <K,V> void getClusterWideMap(String name, Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
name - the name of the mapresultHandler - the map will be returned asynchronously in this handlerpublic <K,V> Observable<AsyncMap<K,V>> getClusterWideMapObservable(String name)
name - the name of the mappublic void getLock(String name, Handler<AsyncResult<Lock>> resultHandler)
name - the name of the lockresultHandler - the handlerpublic Observable<Lock> getLockObservable(String name)
name - the name of the lockpublic void getLockWithTimeout(String name, long timeout, Handler<AsyncResult<Lock>> resultHandler)
getLock(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.shareddata.Lock>>) but specifying a timeout. If the lock is not obtained within the timeout
a failure will be sent to the handlername - the name of the locktimeout - the timeout in msresultHandler - the handlerpublic Observable<Lock> getLockWithTimeoutObservable(String name, long timeout)
getLock(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.shareddata.Lock>>) but specifying a timeout. If the lock is not obtained within the timeout
a failure will be sent to the handlername - the name of the locktimeout - the timeout in mspublic void getCounter(String name, Handler<AsyncResult<Counter>> resultHandler)
name - the name of the counter.resultHandler - the handlerpublic Observable<Counter> getCounterObservable(String name)
name - the name of the counter.public <K,V> LocalMap<K,V> getLocalMap(String name)
LocalMap with the specific name.name - the name of the mappublic static SharedData newInstance(SharedData arg)
Copyright © 2016. All rights reserved.