Package com.sportradar.livedata.sdk.dispatch.livescout

Class LiveScoutDisruptorDispatcher

java.lang.Object

com.sportradar.livedata.sdk.dispatch.DisruptorDispatcher<LiveScoutDispatcherContainer>

com.sportradar.livedata.sdk.dispatch.livescout.LiveScoutDisruptorDispatcher

All Implemented Interfaces:

LiveFeedDispatcher<LiveScoutFeed>, LiveScoutDispatcher

public class LiveScoutDisruptorDispatcher
extends DisruptorDispatcher<LiveScoutDispatcherContainer>
implements LiveScoutDispatcher

A LiveScoutDispatcher implementation which uses disruptor to dispatch messages on multiple threads

Field Summary

Fields inherited from class com.sportradar.livedata.sdk.dispatch.DisruptorDispatcher

dispatcherCount, dispatcherQueueSize, halfDispatcherQueueSize, sdkLogger

Constructor Summary

Constructors

Constructor	Description
LiveScoutDisruptorDispatcher(int dispatcherCount, int dispatcherQueueSize, ExecutorService executor, LiveScoutStatisticsCounter counter)	Initializes a new instance of the LiveScoutDisruptorDispatcher class.

Method Summary

Modifier and Type	Method	Description
protected com.lmax.disruptor.EventHandler<LiveScoutDispatcherContainer>[]	buildConsumers()	Constructs and returns an array of EventHandler instances representing disruptor dispatchers.
void	dispatchEntity(LiveScoutEntityBase entity)	Dispatches the passed LiveScoutEntityBase to the user
void	dispatchOnClosed(LiveScoutFeed sender)
void	dispatchOnFeedEvent(LiveScoutFeed sender, FeedEventType eventType)
void	dispatchOnInitialized(LiveScoutFeed sender)
void	dispatchOnOpened(LiveScoutFeed sender)
void	setFeed(LiveScoutFeed feed)	Set the feed.
void	start(LiveScoutFeedListener listener)	Starts the current LiveScoutDispatcher
void	stop()	Stops the current LiveScoutDispatcher and disposed any resources associated with it.

Methods inherited from class com.sportradar.livedata.sdk.dispatch.DisruptorDispatcher

publish, startDisruptor, stopDisruptor

Methods inherited from class java.lang.Object

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

Constructor Details

LiveScoutDisruptorDispatcher

public LiveScoutDisruptorDispatcher(int dispatcherCount,
 int dispatcherQueueSize,
 ExecutorService executor,
 LiveScoutStatisticsCounter counter)

Initializes a new instance of the LiveScoutDisruptorDispatcher class.

Parameters:

dispatcherCount - The number of the consumers which dispatch events to the user.

dispatcherQueueSize - The size of the disruptor.

executor - The ExecutorService used to spawn background threads

counter - The LiveScoutStatisticsCounter event counter used as JMX MBeans

Method Details

dispatchOnClosed

public void dispatchOnClosed(LiveScoutFeed sender)

Specified by:

dispatchOnClosed in interface LiveFeedDispatcher<LiveScoutFeed>

dispatchOnFeedEvent

public void dispatchOnFeedEvent(LiveScoutFeed sender,
 FeedEventType eventType)

Specified by:

dispatchOnFeedEvent in interface LiveFeedDispatcher<LiveScoutFeed>

dispatchOnInitialized

public void dispatchOnInitialized(LiveScoutFeed sender)

Specified by:

dispatchOnInitialized in interface LiveFeedDispatcher<LiveScoutFeed>

dispatchOnOpened

public void dispatchOnOpened(LiveScoutFeed sender)

Specified by:

dispatchOnOpened in interface LiveFeedDispatcher<LiveScoutFeed>

start

public void start(LiveScoutFeedListener listener)

Starts the current LiveScoutDispatcher

Specified by:

start in interface LiveScoutDispatcher

Parameters:

listener - The LiveScoutFeedListener used by the current LiveScoutFeedListener to dispatch events

stop

public void stop()

Stops the current LiveScoutDispatcher and disposed any resources associated with it.

Specified by:

stop in interface LiveScoutDispatcher

dispatchEntity

public void dispatchEntity(LiveScoutEntityBase entity)
                    throws com.lmax.disruptor.InsufficientCapacityException

Dispatches the passed LiveScoutEntityBase to the user

Specified by:

dispatchEntity in interface LiveScoutDispatcher

Parameters:

entity - the LiveScoutEntityBase to dispatch to the user.

Throws:

com.lmax.disruptor.InsufficientCapacityException - ring buffer is full.

setFeed

public void setFeed(LiveScoutFeed feed)

Set the feed.

Specified by:

setFeed in interface LiveScoutDispatcher

Parameters:

feed - feed that will be served.

buildConsumers

protected com.lmax.disruptor.EventHandler<LiveScoutDispatcherContainer>[] buildConsumers()

Constructs and returns an array of EventHandler instances representing disruptor dispatchers.

Specified by:

buildConsumers in class DisruptorDispatcher<LiveScoutDispatcherContainer>

Returns:

an array of EventHandler instances representing disruptor dispatchers.