Package com.sportradar.unifiedodds.sdk.internal.impl

Class ProducerManagerImpl

java.lang.Object

com.sportradar.unifiedodds.sdk.internal.impl.ProducerManagerImpl

All Implemented Interfaces:

SdkProducerManager, ProducerManager

public class ProducerManagerImpl
extends Object
implements SdkProducerManager

Created on 03/07/2017. // TODO @eti: Javadoc

Constructor Summary

Constructors

Constructor	Description
ProducerManagerImpl(SdkInternalConfiguration configuration, ProducerDataProvider producerDataProvider, TimeUtils time)

Method Summary

Modifier and Type	Method	Description
void	disableProducer(int producerId)	Disables te Producer associated with the provided id (by default all the active producers are enabled)
void	enableProducer(int producerId)	Enables te Producer associated with the provided id (by default all the active producers are enabled)
Map<Integer,Producer>	getActiveProducers()	Returns a Map of activated producers for the provided access token
Map<Integer,Producer>	getAvailableProducers()	Returns a Map of all the available Sportradar producers
Producer	getProducer(int id)	Returns the requested Producer
long	getProducerLastRecoveryAttemptTimestamp(int producerId)
long	getProducerLastRecoveryMessageTimestamp(int producerId)
void	internalSetProducerLastMessageTimestamp(int producerId, long lastMessageTimestamp)
void	internalSetProducerLastRecoveryAttemptTimestamp(int producerId, long lastRecoveryAttemptTimestamp)
void	internalSetProducerLastRecoveryMessageTimestamp(int producerId, long lastRecoveryMessageTimestamp)
boolean	isProducerDown(int producerId)	An indication if the producer is currently marked as down by the SDK
boolean	isProducerEnabled(int producerId)	An indication if the producer is enabled.
void	open()
void	setLastAliveReceivedGenTimestamp(int producerId, long aliveReceivedGenTimestamp)
void	setLastProcessedMessageGenTimestamp(int producerId, long lastProcessedMessageGenTimestamp)
void	setProducerDown(int producerId, boolean flaggedDown)
void	setProducerRecoveryFromTimestamp(int producerId, long lastMessageTimestamp)	Sets the last message received timestamp.
void	setProducerRecoveryInfo(int producerId, RecoveryInfo recoveryInfo)

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerManagerImpl

@Inject
public ProducerManagerImpl(SdkInternalConfiguration configuration,
 ProducerDataProvider producerDataProvider,
 TimeUtils time)

Method Details

getAvailableProducers

public Map<Integer,Producer> getAvailableProducers()

Description copied from interface: ProducerManager

Returns a Map of all the available Sportradar producers

Specified by:

getAvailableProducers in interface ProducerManager

Returns:

- Map of all the available Sportradar producers

getActiveProducers

public Map<Integer,Producer> getActiveProducers()

Description copied from interface: ProducerManager

Returns a Map of activated producers for the provided access token

Specified by:

getActiveProducers in interface ProducerManager

Returns:

- a Map of active producers for the provided access token

getProducer

public Producer getProducer(int id)

Description copied from interface: ProducerManager

Returns the requested Producer

Specified by:

getProducer in interface ProducerManager

Parameters:

id - - the unique identifier of a Producer

Returns:

- if the requested producer exists, a valid Producer instance; otherwise unknown-producer is generated

enableProducer

public void enableProducer(int producerId)

Description copied from interface: ProducerManager

Enables te Producer associated with the provided id (by default all the active producers are enabled)

Specified by:

enableProducer in interface ProducerManager

Parameters:

producerId - - the identifier of the producer that you want to enable

disableProducer

public void disableProducer(int producerId)

Description copied from interface: ProducerManager

Disables te Producer associated with the provided id (by default all the active producers are enabled)

Specified by:

disableProducer in interface ProducerManager

Parameters:

producerId - - the identifier of the producer that you want to disable

setProducerRecoveryFromTimestamp

public void setProducerRecoveryFromTimestamp(int producerId,
 long lastMessageTimestamp)

Description copied from interface: ProducerManager

Sets the last message received timestamp. The value should be set to the timestamp of the last processed message, which was received while the producer was not marked as down. The timestamp is later used to request the feed recovery. The last valid max timestamp is 3 days ago (recovery limitation). See: Producer.getTimestampForRecovery()

Specified by:

setProducerRecoveryFromTimestamp in interface ProducerManager

Parameters:

producerId - - the identifier of the producer to which the last known message timestamp belongs too

lastMessageTimestamp - - the timestamp from which the SDK will request the recovery (in milliseconds)

isProducerEnabled

public boolean isProducerEnabled(int producerId)

Description copied from interface: ProducerManager

An indication if the producer is enabled.

Specified by:

isProducerEnabled in interface ProducerManager

Parameters:

producerId - - the identifier of the producer for which to check

Returns:

- true if the producer is enabled, otherwise false

isProducerDown

public boolean isProducerDown(int producerId)

Description copied from interface: ProducerManager

An indication if the producer is currently marked as down by the SDK

Specified by:

isProducerDown in interface ProducerManager

Parameters:

producerId - - the identifier of the producer for which to check

Returns:

- true if the producer is down, otherwise false

See Also:

• ProducerDownReason

open

public void open()

Specified by:

open in interface SdkProducerManager

setProducerDown

public void setProducerDown(int producerId,
 boolean flaggedDown)

Specified by:

setProducerDown in interface SdkProducerManager

internalSetProducerLastMessageTimestamp

public void internalSetProducerLastMessageTimestamp(int producerId,
 long lastMessageTimestamp)

Specified by:

internalSetProducerLastMessageTimestamp in interface SdkProducerManager

internalSetProducerLastRecoveryMessageTimestamp

public void internalSetProducerLastRecoveryMessageTimestamp(int producerId,
 long lastRecoveryMessageTimestamp)

Specified by:

internalSetProducerLastRecoveryMessageTimestamp in interface SdkProducerManager

setLastProcessedMessageGenTimestamp

public void setLastProcessedMessageGenTimestamp(int producerId,
 long lastProcessedMessageGenTimestamp)

Specified by:

setLastProcessedMessageGenTimestamp in interface SdkProducerManager

setLastAliveReceivedGenTimestamp

public void setLastAliveReceivedGenTimestamp(int producerId,
 long aliveReceivedGenTimestamp)

Specified by:

setLastAliveReceivedGenTimestamp in interface SdkProducerManager

setProducerRecoveryInfo

public void setProducerRecoveryInfo(int producerId,
 RecoveryInfo recoveryInfo)

Specified by:

setProducerRecoveryInfo in interface SdkProducerManager

getProducerLastRecoveryMessageTimestamp

public long getProducerLastRecoveryMessageTimestamp(int producerId)

Specified by:

getProducerLastRecoveryMessageTimestamp in interface SdkProducerManager

internalSetProducerLastRecoveryAttemptTimestamp

public void internalSetProducerLastRecoveryAttemptTimestamp(int producerId,
 long lastRecoveryAttemptTimestamp)

Specified by:

internalSetProducerLastRecoveryAttemptTimestamp in interface SdkProducerManager

getProducerLastRecoveryAttemptTimestamp

public long getProducerLastRecoveryAttemptTimestamp(int producerId)

Specified by:

getProducerLastRecoveryAttemptTimestamp in interface SdkProducerManager