Package com.sportradar.livedata.sdk.proto.common

Class RequestProducerBase<T extends OutgoingMessage>

java.lang.Object

com.sportradar.livedata.sdk.proto.common.RequestProducerBase<T>

Type Parameters:

T - The type of the requests produced by the current RequestProducerBase

All Implemented Interfaces:

RequestProducer<T>

Direct Known Subclasses:

LiveScoutClientAliveProducer, LiveScoutUserRequestManagerImpl, RequestProducerComposite

public abstract class RequestProducerBase<T extends OutgoingMessage>
extends Object
implements RequestProducer<T>

A base class for all classes implementing RequestProducer interface.

Constructor Summary

Constructors

Constructor	Description
RequestProducerBase()

Method Summary

Modifier and Type	Method	Description
protected boolean	getIsStarted()	Gets the value specifying whether the current RequestProducerBase is started.
protected boolean	notifyOnRequestReady(T message)
protected boolean	notifyOnRequestReady(T message, boolean blocking)	Notifies the observer that new request is ready to be send to the server.
protected void	onStarting()	Invoked by the current RequestProducerBase when it is starting.
protected void	onStopping()	Invoked by the current RequestProducerBase when it is stopping.
void	setListener(RequestProducerListener<T> listener)	Sets the RequestProducerListener used to observe the current RequestProducer
void	start()	Instructs the RequestProducer to start generating requests.
void	stop()	Instructs the RequestProducer to stop generating requests;

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestProducerBase

public RequestProducerBase()

Method Detail

setListener

public final void setListener(RequestProducerListener<T> listener)

Sets the RequestProducerListener used to observe the current RequestProducer

Specified by:

setListener in interface RequestProducer<T extends OutgoingMessage>

Parameters:

listener - The listener used to observer the current RequestProducer

start

public final void start()

Instructs the RequestProducer to start generating requests.

Specified by:

start in interface RequestProducer<T extends OutgoingMessage>

onStarting

protected void onStarting()

Invoked by the current RequestProducerBase when it is starting. Note that the method is called within critical region, so make sure the execution does not leave the derived class.

stop

public final void stop()

Instructs the RequestProducer to stop generating requests;

Specified by:

stop in interface RequestProducer<T extends OutgoingMessage>

onStopping

protected void onStopping()

Invoked by the current RequestProducerBase when it is stopping. Note that the method is called withing critical region, so make sure the execution does not leave the derived class.

getIsStarted

protected boolean getIsStarted()

Gets the value specifying whether the current RequestProducerBase is started.

Returns:

the value specifying whether the current RequestProducerBase is started.

notifyOnRequestReady

protected boolean notifyOnRequestReady(T message)

notifyOnRequestReady

protected boolean notifyOnRequestReady(T message,
                                       boolean blocking)

Notifies the observer that new request is ready to be send to the server.

Parameters:

message - the T representing the request to be send to the betradar server.

blocking - determine if request must be blocking.

Returns:

true is success.