public class FeedMessageFactoryImpl extends Object implements FeedMessageFactory
Constructor and Description |
---|
FeedMessageFactoryImpl(MarketFactory marketFactory,
NamedValuesProvider namedValuesProvider,
SdkProducerManager producerManager) |
Modifier and Type | Method and Description |
---|---|
<T extends SportEvent> |
buildBetCancel(T sportEvent,
com.sportradar.uf.datamodel.UfBetCancel message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
buildBetSettlement(T sportEvent,
com.sportradar.uf.datamodel.UfBetSettlement message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
buildBetStop(T sportEvent,
com.sportradar.uf.datamodel.UfBetStop message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
buildCashOutProbabilities(T sportEvent,
com.sportradar.uf.datamodel.UfCashout cashoutData,
MessageTimestamp timestamp) |
<T extends SportEvent> |
buildFixtureChange(T sportEvent,
com.sportradar.uf.datamodel.UfFixtureChange message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
buildOddsChange(T sportEvent,
com.sportradar.uf.datamodel.UfOddsChange message,
byte[] rawMessage,
MessageTimestamp timestamp) |
ProducerStatus |
buildProducerStatus(int producerId,
ProducerStatusReason reason,
boolean isDown,
boolean isDelayed,
long timestamp) |
RecoveryInitiated |
buildRecoveryInitiated(int producerId,
long requestId,
Long after,
Urn eventId,
String message,
long timestamp) |
<T extends SportEvent> |
buildRollbackBetCancel(T sportEvent,
com.sportradar.uf.datamodel.UfRollbackBetCancel message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
buildRollbackBetSettlement(T sportEvent,
com.sportradar.uf.datamodel.UfRollbackBetSettlement message,
byte[] rawMessage,
MessageTimestamp timestamp) |
<T extends SportEvent> |
buildUnparsableMessage(T sportEvent,
Integer producerId,
byte[] rawMessage,
MessageTimestamp timestamp) |
@Inject public FeedMessageFactoryImpl(MarketFactory marketFactory, NamedValuesProvider namedValuesProvider, SdkProducerManager producerManager)
public ProducerStatus buildProducerStatus(int producerId, ProducerStatusReason reason, boolean isDown, boolean isDelayed, long timestamp)
buildProducerStatus
in interface FeedMessageFactory
public RecoveryInitiated buildRecoveryInitiated(int producerId, long requestId, Long after, Urn eventId, String message, long timestamp)
buildRecoveryInitiated
in interface FeedMessageFactory
public <T extends SportEvent> BetStop<T> buildBetStop(T sportEvent, com.sportradar.uf.datamodel.UfBetStop message, byte[] rawMessage, MessageTimestamp timestamp)
buildBetStop
in interface FeedMessageFactory
public <T extends SportEvent> FixtureChange<T> buildFixtureChange(T sportEvent, com.sportradar.uf.datamodel.UfFixtureChange message, byte[] rawMessage, MessageTimestamp timestamp)
buildFixtureChange
in interface FeedMessageFactory
public <T extends SportEvent> BetSettlement<T> buildBetSettlement(T sportEvent, com.sportradar.uf.datamodel.UfBetSettlement message, byte[] rawMessage, MessageTimestamp timestamp)
buildBetSettlement
in interface FeedMessageFactory
public <T extends SportEvent> RollbackBetSettlement<T> buildRollbackBetSettlement(T sportEvent, com.sportradar.uf.datamodel.UfRollbackBetSettlement message, byte[] rawMessage, MessageTimestamp timestamp)
buildRollbackBetSettlement
in interface FeedMessageFactory
public <T extends SportEvent> OddsChange<T> buildOddsChange(T sportEvent, com.sportradar.uf.datamodel.UfOddsChange message, byte[] rawMessage, MessageTimestamp timestamp)
buildOddsChange
in interface FeedMessageFactory
public <T extends SportEvent> RollbackBetCancel<T> buildRollbackBetCancel(T sportEvent, com.sportradar.uf.datamodel.UfRollbackBetCancel message, byte[] rawMessage, MessageTimestamp timestamp)
buildRollbackBetCancel
in interface FeedMessageFactory
public <T extends SportEvent> BetCancel<T> buildBetCancel(T sportEvent, com.sportradar.uf.datamodel.UfBetCancel message, byte[] rawMessage, MessageTimestamp timestamp)
buildBetCancel
in interface FeedMessageFactory
public <T extends SportEvent> CashOutProbabilities<T> buildCashOutProbabilities(T sportEvent, com.sportradar.uf.datamodel.UfCashout cashoutData, MessageTimestamp timestamp)
buildCashOutProbabilities
in interface FeedMessageFactory
public <T extends SportEvent> UnparsableMessage<T> buildUnparsableMessage(T sportEvent, Integer producerId, byte[] rawMessage, MessageTimestamp timestamp)
buildUnparsableMessage
in interface FeedMessageFactory
Copyright © 2016–2025. All rights reserved.