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

Interface FeedMessageProcessor

All Known Subinterfaces:

CompositeFeedMessageProcessor

All Known Implementing Classes:

CacheMessageProcessor, CompositeMessageProcessor, UofSessionImpl

public interface FeedMessageProcessor

Defines methods implemented by classes capable of processing feed messages

Method Summary

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

Method Details

getProcessorId

String getProcessorId()

Returns the processor identifier

Returns:

- the processor identifier

processMessage

void processMessage(UnmarshalledMessage message,
 byte[] body,
 RoutingKeyInfo routingKeyInfo,
 MessageTimestamp timestamp,
 Map<String,String> messageHeaders)

Processes the provided message. If the next message processor is defined through the setNextMessageProcessor(FeedMessageProcessor), the instance should forward the message to the defined next message processor after the processing is completed

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

setNextMessageProcessor

void setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)

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

Parameters:

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