Package org.apache.bookkeeper.common.component

Class RxSchedulerLifecycleComponent

java.lang.Object

org.apache.bookkeeper.common.component.AbstractComponent<ConfT>

org.apache.bookkeeper.common.component.AbstractLifecycleComponent<ComponentConfiguration>

org.apache.bookkeeper.common.component.RxSchedulerLifecycleComponent

All Implemented Interfaces:

AutoCloseable, LifecycleComponent

public class RxSchedulerLifecycleComponent
extends AbstractLifecycleComponent<ComponentConfiguration>

The scheduler for rxjava based jobs, such as data integrity checking.

Field Summary

Fields inherited from class org.apache.bookkeeper.common.component.AbstractLifecycleComponent

lifecycle, statsLogger, uncaughtExceptionHandler

Fields inherited from class org.apache.bookkeeper.common.component.AbstractComponent

componentName, conf

Constructor Summary

Constructors

Constructor	Description
RxSchedulerLifecycleComponent(String componentName, ComponentConfiguration conf, StatsLogger stats, io.reactivex.rxjava3.core.Scheduler scheduler, ExecutorService rxExecutor)

Method Summary

Modifier and Type	Method	Description
void	doClose()
protected void	doStart()
protected void	doStop()

Methods inherited from class org.apache.bookkeeper.common.component.AbstractLifecycleComponent

addLifecycleListener, close, getStatsLogger, lifecycleState, removeLifecycleListener, setExceptionHandler, start, stop

Methods inherited from class org.apache.bookkeeper.common.component.AbstractComponent

getConf, getName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.common.component.LifecycleComponent

getName, publishInfo

Constructor Details

RxSchedulerLifecycleComponent

public RxSchedulerLifecycleComponent(String componentName,
 ComponentConfiguration conf,
 StatsLogger stats,
 io.reactivex.rxjava3.core.Scheduler scheduler,
 ExecutorService rxExecutor)

Method Details

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent<ComponentConfiguration>

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent<ComponentConfiguration>

doClose

public void doClose()

Specified by:

doClose in class AbstractLifecycleComponent<ComponentConfiguration>