jayeson.lib.sports.client

Class SportsFeedClient

java.lang.Object

jayeson.lib.sports.client.SportsFeedClient

public class SportsFeedClient
extends java.lang.Object

SportsFeedClient is created by SportsFeedFactory to consume Feed with loaded configurations

Constructor Summary

Constructors

Constructor and Description
SportsFeedClient(jayeson.lib.delivery.module.subscriber.ISubscriber subscriber, jayeson.lib.sports.receive.SportsFeedInConfig config, FeedView<IBetMatch> viewTemplate, jayeson.lib.sports.receive.InEndPointEventHandler eventHandler, jayeson.lib.sports.receive.SportsFeedInProcessor inProcessor, java.util.concurrent.ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
jayeson.lib.delivery.module.subscriber.ISubscriber	getSubscriber() Retrieve subscriber which is responsible for reading stream and connect to the stream
void	onSwitchFilterFail(int requestId)
void	onSwitchFilterStart(int requestId)
<M extends IBetMatch> void	removeView(FeedView<M> view) Releases the resources associated with the view.
java.util.Map<java.util.concurrent.CompletableFuture<java.lang.Void>,jayeson.lib.delivery.api.IEndPoint>	sendKeepAlive() Sends keepalive and returns a future which will complete upon receiving a response.
java.util.Map<java.util.concurrent.CompletableFuture<java.lang.Void>,jayeson.lib.delivery.api.IEndPoint>	sendKeepAlive(long timeOut) Sends keepalive and returns a future which will complete upon receiving a response.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	setUpStreamFilter(jayeson.lib.sports.codec.FilterData filterData) Set this filter to upstream.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	setUpStreamFilter(jayeson.lib.sports.codec.FilterData filterData, boolean initialFilter) Set this filter to upstream.
void	start() Starts Subscriber
<M extends IBetMatch> FeedView<M>	view(java.lang.Class<M> clazz) Create view without filter
<M extends IBetMatch> FeedView<M>	view(jayeson.model.IDataFilter filter, java.lang.Class<M> clazz) Create a view with filter

Methods inherited from class java.lang.Object

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

Methods inherited from interface jayeson.lib.sports.client.DeltaEventHandler

onDeleteEvent, onDeleteMatch, onDeleteOdd, onFullSnapshotEnd, onFullSnapshotStart, onInsertEvent, onInsertMatch, onInsertOdd, onRefresh, onReset, onSwitchFilterEnd, onSwitchFilterFail, onSwitchFilterStart, onUpdateEvent, onUpdateMatch, onUpdateOdd

Constructor Detail

SportsFeedClient

@Inject
public SportsFeedClient(jayeson.lib.delivery.module.subscriber.ISubscriber subscriber,
                                 jayeson.lib.sports.receive.SportsFeedInConfig config,
                                 FeedView<IBetMatch> viewTemplate,
                                 jayeson.lib.sports.receive.InEndPointEventHandler eventHandler,
                                 jayeson.lib.sports.receive.SportsFeedInProcessor inProcessor,
                                 java.util.concurrent.ScheduledExecutorService executor)

Method Detail

setUpStreamFilter

public java.util.concurrent.CompletableFuture<java.lang.Boolean> setUpStreamFilter(jayeson.lib.sports.codec.FilterData filterData)

Set this filter to upstream. Null implies empty filter

Parameters:

filterData - - rules

setUpStreamFilter

public java.util.concurrent.CompletableFuture<java.lang.Boolean> setUpStreamFilter(jayeson.lib.sports.codec.FilterData filterData,
                                                                                   boolean initialFilter)

Set this filter to upstream. Null implies empty filter

Parameters:

filterData - The filters

initialFilter - Whether it is initial filter or not

onSwitchFilterFail

public void onSwitchFilterFail(int requestId)

onSwitchFilterStart

public void onSwitchFilterStart(int requestId)

getSubscriber

public jayeson.lib.delivery.module.subscriber.ISubscriber getSubscriber()

Retrieve subscriber which is responsible for reading stream and connect to the stream

start

public void start()

Starts Subscriber

view

public <M extends IBetMatch> FeedView<M> view(java.lang.Class<M> clazz)

Create view without filter

Parameters:

clazz - - can be one of IBetMatch/IB2Match/(Sports specific match like SoccerMatch/TennisMatch/BasketballMatch)

view

public <M extends IBetMatch> FeedView<M> view(jayeson.model.IDataFilter filter,
                                              java.lang.Class<M> clazz)

Create a view with filter

Parameters:

clazz - - can be one of IBetMatch/IB2Match/(Sports specific match like SoccerMatch/TennisMatch/BasketballMatch)

removeView

public <M extends IBetMatch> void removeView(FeedView<M> view)

Releases the resources associated with the view.

Parameters:

view -

sendKeepAlive

public java.util.Map<java.util.concurrent.CompletableFuture<java.lang.Void>,jayeson.lib.delivery.api.IEndPoint> sendKeepAlive()

Sends keepalive and returns a future which will complete upon receiving a response.

Returns:

sendKeepAlive

public java.util.Map<java.util.concurrent.CompletableFuture<java.lang.Void>,jayeson.lib.delivery.api.IEndPoint> sendKeepAlive(long timeOut)

Sends keepalive and returns a future which will complete upon receiving a response. If no responses are received within timeOut milliseconds, a timeout exception will be thrown.

Parameters:

timeOut -

Returns: