Package io.split.engine.sse

Class NotificationProcessorImp

java.lang.Object

io.split.engine.sse.NotificationProcessorImp

All Implemented Interfaces:

NotificationProcessor

public class NotificationProcessorImp
extends Object
implements NotificationProcessor

Method Summary

Modifier and Type	Method	Description
static NotificationProcessorImp	build(FeatureFlagsWorker featureFlagsWorker, Worker<SegmentQueueDto> segmentWorker, PushStatusTracker pushStatusTracker)
void	process(IncomingNotification notification)
void	processSegmentUpdate(long changeNumber, String segmentName)
void	processSplitKill(SplitKillNotification splitKillNotification)
void	processStatus(StatusNotification statusNotification)
void	processUpdates(IncomingNotification notification)

Methods inherited from class java.lang.Object

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

Method Detail

build

public static NotificationProcessorImp build(FeatureFlagsWorker featureFlagsWorker,
                                             Worker<SegmentQueueDto> segmentWorker,
                                             PushStatusTracker pushStatusTracker)

processUpdates

public void processUpdates(IncomingNotification notification)

Specified by:

processUpdates in interface NotificationProcessor

process

public void process(IncomingNotification notification)

Specified by:

process in interface NotificationProcessor

processSplitKill

public void processSplitKill(SplitKillNotification splitKillNotification)

Specified by:

processSplitKill in interface NotificationProcessor

processSegmentUpdate

public void processSegmentUpdate(long changeNumber,
                                 String segmentName)

Specified by:

processSegmentUpdate in interface NotificationProcessor

processStatus

public void processStatus(StatusNotification statusNotification)

Specified by:

processStatus in interface NotificationProcessor