org.apache.twill.zookeeper

Class ForwardingZKClientService

java.lang.Object

org.apache.twill.zookeeper.AbstractZKClient

org.apache.twill.zookeeper.ForwardingZKClient

org.apache.twill.zookeeper.ForwardingZKClientService

All Implemented Interfaces:

com.google.common.util.concurrent.Service, ZKClient, ZKClientService

public abstract class ForwardingZKClientService
extends ForwardingZKClient
implements ZKClientService

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.twill.zookeeper.ZKClientService

ZKClientService.Builder

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ForwardingZKClientService(ZKClientService delegate)

Method Summary

Modifier and Type	Method and Description
void	addListener(com.google.common.util.concurrent.Service.Listener listener, Executor executor)
com.google.common.base.Supplier<org.apache.zookeeper.ZooKeeper>	getZooKeeperSupplier() Returns a Supplier of ZooKeeper that gives the current ZooKeeper in use at the moment when Supplier.get() get called.
boolean	isRunning()
com.google.common.util.concurrent.ListenableFuture<com.google.common.util.concurrent.Service.State>	start()
com.google.common.util.concurrent.Service.State	startAndWait()
com.google.common.util.concurrent.Service.State	state()
com.google.common.util.concurrent.ListenableFuture<com.google.common.util.concurrent.Service.State>	stop()
com.google.common.util.concurrent.Service.State	stopAndWait()

Methods inherited from class org.apache.twill.zookeeper.ForwardingZKClient

addConnectionWatcher, create, delete, exists, getACL, getChildren, getConnectString, getData, getDelegate, getSessionId, setACL, setData

Methods inherited from class org.apache.twill.zookeeper.AbstractZKClient

create, create, create, delete, exists, getChildren, getData, setACL, setData

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.twill.zookeeper.ZKClient

addConnectionWatcher, create, create, create, create, delete, delete, exists, exists, getACL, getChildren, getChildren, getConnectString, getData, getData, getSessionId, setACL, setACL, setData, setData

Methods inherited from interface com.google.common.util.concurrent.Service

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, startAsync, stopAsync

Constructor Detail

ForwardingZKClientService

protected ForwardingZKClientService(ZKClientService delegate)

Method Detail

getZooKeeperSupplier

public com.google.common.base.Supplier<org.apache.zookeeper.ZooKeeper> getZooKeeperSupplier()

Description copied from interface: ZKClientService

Returns a Supplier of ZooKeeper that gives the current ZooKeeper in use at the moment when Supplier.get() get called.

Specified by:

getZooKeeperSupplier in interface ZKClientService

Returns:

A Supplier<ZooKeeper>

start

public com.google.common.util.concurrent.ListenableFuture<com.google.common.util.concurrent.Service.State> start()

Specified by:

start in interface com.google.common.util.concurrent.Service

startAndWait

public com.google.common.util.concurrent.Service.State startAndWait()

Specified by:

startAndWait in interface com.google.common.util.concurrent.Service

isRunning

public boolean isRunning()

Specified by:

isRunning in interface com.google.common.util.concurrent.Service

state

public com.google.common.util.concurrent.Service.State state()

Specified by:

state in interface com.google.common.util.concurrent.Service

stop

public com.google.common.util.concurrent.ListenableFuture<com.google.common.util.concurrent.Service.State> stop()

Specified by:

stop in interface com.google.common.util.concurrent.Service

stopAndWait

public com.google.common.util.concurrent.Service.State stopAndWait()

Specified by:

stopAndWait in interface com.google.common.util.concurrent.Service

addListener

public void addListener(com.google.common.util.concurrent.Service.Listener listener,
                        Executor executor)

Specified by:

addListener in interface com.google.common.util.concurrent.Service