Package io.split.engine.sse.workers

Class FeatureFlagWorkerImp

java.lang.Object

io.split.engine.sse.workers.Worker<IncomingNotification>

io.split.engine.sse.workers.FeatureFlagWorkerImp

All Implemented Interfaces:

FeatureFlagsWorker, Runnable

public class FeatureFlagWorkerImp
extends Worker<IncomingNotification>
implements FeatureFlagsWorker

Field Summary

Fields inherited from class io.split.engine.sse.workers.Worker

_queue, _running, _thread

Constructor Summary

Constructors

Constructor	Description
FeatureFlagWorkerImp(Synchronizer synchronizer, SplitParser splitParser, RuleBasedSegmentParser ruleBasedSegmentParser, SplitCacheProducer splitCacheProducer, RuleBasedSegmentCache ruleBasedSegmentCache, TelemetryRuntimeProducer telemetryRuntimeProducer, FlagSetsFilter flagSetsFilter)

Method Summary

Modifier and Type	Method	Description
protected void	executeRefresh(IncomingNotification incomingNotification)
void	kill(SplitKillNotification splitKillNotification)

Methods inherited from class io.split.engine.sse.workers.Worker

addToQueue, run, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.split.engine.sse.workers.FeatureFlagsWorker

addToQueue, start, stop

Constructor Detail

FeatureFlagWorkerImp

public FeatureFlagWorkerImp(Synchronizer synchronizer,
                            SplitParser splitParser,
                            RuleBasedSegmentParser ruleBasedSegmentParser,
                            SplitCacheProducer splitCacheProducer,
                            RuleBasedSegmentCache ruleBasedSegmentCache,
                            TelemetryRuntimeProducer telemetryRuntimeProducer,
                            FlagSetsFilter flagSetsFilter)

Method Detail

kill

public void kill(SplitKillNotification splitKillNotification)

Specified by:

kill in interface FeatureFlagsWorker

executeRefresh

protected void executeRefresh(IncomingNotification incomingNotification)

Specified by:

executeRefresh in class Worker<IncomingNotification>