com.sportradar.unifiedodds.sdk.internal.impl

Class UofSessionImpl

java.lang.Object

com.sportradar.unifiedodds.sdk.internal.impl.UofSessionImpl

All Implemented Interfaces:

FeedMessageProcessor, MessageConsumer, UofSession

public class UofSessionImpl
extends Object
implements UofSession, MessageConsumer, FeedMessageProcessor

Constructor Summary

Constructors

Constructor and Description

UofSessionImpl(SdkInternalConfiguration config, MessageReceiver messageReceiver, RecoveryManager recoveryManager, CompositeMessageProcessor messageProcessor, SdkProducerManager producerManager, SportDataProvider sportDataProvider, SportEntityFactory sportEntityFactory, FeedMessageFactory messageFactory, FeedMessageValidator feedMessageValidator, UnifiedOddsStatistics ufStats, com.google.common.cache.Cache<String,String> dispatchedFixtureChangesCache)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	equals(Object obj)
String	getConsumerDescription() Returns a String which describes the consumer
MessageInterest	getMessageInterest() Returns the consumer MessageInterest
String	getProcessorId() Returns the processor identifier
int	hashCode()
void	onMessageDeserializationFailed(byte[] rawMessage, Urn eventId) Dispatches the "unparsable message received event"
void	onMessageReceived(UnmarshalledMessage unmarshalledMessage, byte[] body, RoutingKeyInfo routingKeyInfo, MessageTimestamp timestamp) Consumes the provided message
void	onRawFeedMessageReceived(RoutingKeyInfo routingKey, UnmarshalledMessage feedMessage, MessageTimestamp timestamp, MessageInterest messageInterest) Occurs when any feed message arrives
void	open(List<String> routingKeys, MessageInterest messageInterest, UofListener uofListener, UofExtListener uofExtListener)
void	processMessage(UnmarshalledMessage o, byte[] body, RoutingKeyInfo routingKeyInfo, MessageTimestamp timestamp) Dispatches the processed message to the client
void	setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor) This method should be ignored since the UofSessionImpl is the final dispatching message processor.

Methods inherited from class java.lang.Object

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

Constructor Detail

UofSessionImpl

@Inject
public UofSessionImpl(SdkInternalConfiguration config,
                              MessageReceiver messageReceiver,
                              RecoveryManager recoveryManager,
                              CompositeMessageProcessor messageProcessor,
                              SdkProducerManager producerManager,
                              SportDataProvider sportDataProvider,
                              SportEntityFactory sportEntityFactory,
                              FeedMessageFactory messageFactory,
                              FeedMessageValidator feedMessageValidator,
                              UnifiedOddsStatistics ufStats,
                              com.google.common.cache.Cache<String,String> dispatchedFixtureChangesCache)

Method Detail

open

public void open(List<String> routingKeys,
                 MessageInterest messageInterest,
                 UofListener uofListener,
                 UofExtListener uofExtListener)
          throws IOException

Throws:

IOException

close

public void close()

onMessageReceived

public void onMessageReceived(UnmarshalledMessage unmarshalledMessage,
                              byte[] body,
                              RoutingKeyInfo routingKeyInfo,
                              MessageTimestamp timestamp)

Consumes the provided message

Specified by:

onMessageReceived in interface MessageConsumer

Parameters:

unmarshalledMessage - - an unmarshalled message payload

body - - the raw payload (mainly used for logging and user exposure)

routingKeyInfo - - a RoutingKeyInfo instance describing the message routing key

timestamp - - all message timestamps

onMessageDeserializationFailed

public void onMessageDeserializationFailed(byte[] rawMessage,
                                           Urn eventId)

Dispatches the "unparsable message received event"

Specified by:

onMessageDeserializationFailed in interface MessageConsumer

Parameters:

rawMessage - - the raw message payload

eventId - - if available the related sport event id; otherwise null

getProcessorId

public String getProcessorId()

Returns the processor identifier

Specified by:

getProcessorId in interface FeedMessageProcessor

Returns:

- the processor identifier

processMessage

public void processMessage(UnmarshalledMessage o,
                           byte[] body,
                           RoutingKeyInfo routingKeyInfo,
                           MessageTimestamp timestamp)

Dispatches the processed message to the client

Specified by:

processMessage in interface FeedMessageProcessor

Parameters:

o - - the message that should be processed

body - - the raw body of the received message

routingKeyInfo - - a RoutingKeyInfo instance describing the message routing key

timestamp - - all message timestamps

setNextMessageProcessor

public void setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)

This method should be ignored since the UofSessionImpl is the final dispatching message processor.

Specified by:

setNextMessageProcessor in interface FeedMessageProcessor

Parameters:

nextMessageProcessor - - should be ignored/not used

getConsumerDescription

public String getConsumerDescription()

Returns a String which describes the consumer

Specified by:

getConsumerDescription in interface MessageConsumer

Returns:

- a String which describes the consumer

getMessageInterest

public MessageInterest getMessageInterest()

Returns the consumer MessageInterest

Specified by:

getMessageInterest in interface MessageConsumer

Returns:

the consumer MessageInterest

onRawFeedMessageReceived

public void onRawFeedMessageReceived(RoutingKeyInfo routingKey,
                                     UnmarshalledMessage feedMessage,
                                     MessageTimestamp timestamp,
                                     MessageInterest messageInterest)

Occurs when any feed message arrives

Specified by:

onRawFeedMessageReceived in interface MessageConsumer

Parameters:

routingKey - the routing key associated with this message

feedMessage - the message received

timestamp - the message timestamps

messageInterest - the associated MessageInterest

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object