Package org.apache.bookkeeper.discover

Class ZKRegistrationClient.WatchTask

java.lang.Object

org.apache.bookkeeper.discover.ZKRegistrationClient.WatchTask

All Implemented Interfaces:

AutoCloseable, Runnable, BiConsumer<Versioned<Set<BookieId>>,Throwable>, org.apache.zookeeper.Watcher

Enclosing class:

ZKRegistrationClient

class ZKRegistrationClient.WatchTask
extends Object
implements Runnable, org.apache.zookeeper.Watcher, BiConsumer<Versioned<Set<BookieId>>,Throwable>, AutoCloseable

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event, org.apache.zookeeper.Watcher.WatcherType

Constructor Summary

Constructors

Constructor	Description
WatchTask(String regPath, CompletableFuture<Void> firstRunFuture)

Method Summary

Modifier and Type	Method	Description
void	accept(Versioned<Set<BookieId>> bookieSet, Throwable throwable)
boolean	addListener(RegistrationClient.RegistrationListener listener)
void	close()
int	getNumListeners()
(package private) boolean	isClosed()
void	process(org.apache.zookeeper.WatchedEvent event)
boolean	removeListener(RegistrationClient.RegistrationListener listener)
void	run()
(package private) void	watch()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.BiConsumer

andThen

Constructor Details

WatchTask

WatchTask(String regPath,
 CompletableFuture<Void> firstRunFuture)

Method Details

getNumListeners

public int getNumListeners()

addListener

public boolean addListener(RegistrationClient.RegistrationListener listener)

removeListener

public boolean removeListener(RegistrationClient.RegistrationListener listener)

watch

void watch()

run

public void run()

Specified by:

run in interface Runnable

accept

public void accept(Versioned<Set<BookieId>> bookieSet,
 Throwable throwable)

Specified by:

accept in interface BiConsumer<Versioned<Set<BookieId>>,Throwable>

process

public void process(org.apache.zookeeper.WatchedEvent event)

Specified by:

process in interface org.apache.zookeeper.Watcher

isClosed

boolean isClosed()

close

public void close()

Specified by:

close in interface AutoCloseable