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

Class CacheMessageProcessor

java.lang.Object

com.sportradar.unifiedodds.sdk.internal.impl.processing.pipeline.CacheMessageProcessor

All Implemented Interfaces:

FeedMessageProcessor

public class CacheMessageProcessor
extends Object
implements FeedMessageProcessor

A FeedMessageProcessor implementation which is used in the message processing pipeline

Constructor Summary

Constructors

Constructor	Description
CacheMessageProcessor(SportEventStatusCache sportEventStatusCache, SportEventCache sportEventCache, ProcessedFixtureChangesTracker processedFixtureChangesTracker, SdkProducerManager producerManager)	Initializes a new CacheMessageProcessor instance

Method Summary

Modifier and Type	Method	Description
String	getProcessorId()	Returns the processor identifier
void	processMessage(UnmarshalledMessage message, byte[] body, RoutingKeyInfo routingKeyInfo, MessageTimestamp timestamp)	Processes the provided message.
void	setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)	Sets the next message processor that should be invoked after the message processing is finished

Methods inherited from class java.lang.Object

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

Constructor Details

CacheMessageProcessor

public CacheMessageProcessor(SportEventStatusCache sportEventStatusCache,
 SportEventCache sportEventCache,
 ProcessedFixtureChangesTracker processedFixtureChangesTracker,
 SdkProducerManager producerManager)

Initializes a new CacheMessageProcessor instance

Parameters:

sportEventStatusCache - the SportEventStatusCache used by the associated SDK instance

sportEventCache - the SportEventCache used by the associated SDK instance

processedFixtureChangesTracker - used to track processed fixture change messages

producerManager - to get 'virtual' producers to ignore for fixture_change_fixture endpoint

Method Details

processMessage

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

Processes the provided message. If the nextMessageProcessor is defined, the instance will forward the message to the nextMessageProcessor

Specified by:

processMessage in interface FeedMessageProcessor

Parameters:

message - - 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

getProcessorId

public String getProcessorId()

Description copied from interface: FeedMessageProcessor

Returns the processor identifier

Specified by:

getProcessorId in interface FeedMessageProcessor

Returns:

- the processor identifier

setNextMessageProcessor

public void setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)

Description copied from interface: FeedMessageProcessor

Sets the next message processor that should be invoked after the message processing is finished

Specified by:

setNextMessageProcessor in interface FeedMessageProcessor

Parameters:

nextMessageProcessor - - the FeedMessageProcessor implementation that should be invoked after the message process is finished