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

Class CompositeMessageProcessor

java.lang.Object

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

All Implemented Interfaces:

CompositeFeedMessageProcessor, FeedMessageProcessor

public class CompositeMessageProcessor
extends Object
implements CompositeFeedMessageProcessor

The master FeedMessageProcessor implementation that handles the flow through the message processing pipeline

Constructor Summary

Constructors

Constructor	Description
CompositeMessageProcessor(List<FeedMessageProcessor> processors)	Constructs a new CompositeMessageProcessor instance

Method Summary

Modifier and Type	Method	Description
String	getProcessorId()	Returns the processor identifier
void	init(FeedMessageProcessor dispatchingProcessor)	Initializes and prepares the composite processor instance
void	processMessage(UnmarshalledMessage message, byte[] body, RoutingKeyInfo routingKeyInfo, MessageTimestamp timestamp)	Starts the processing pipeline by calling the firstProcessor
void	setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)	This method should be ignored since the CompositeMessageProcessor is the trigger/starter of the processing pipeline and can't have a successor processor

Methods inherited from class java.lang.Object

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

Constructor Details

CompositeMessageProcessor

public CompositeMessageProcessor(List<FeedMessageProcessor> processors)

Constructs a new CompositeMessageProcessor instance

Parameters:

processors - - a completeList pipeline processors

Method Details

init

public void init(FeedMessageProcessor dispatchingProcessor)

Initializes and prepares the composite processor instance

Specified by:

init in interface CompositeFeedMessageProcessor

Parameters:

dispatchingProcessor - - the final dispatching message processor

getProcessorId

public String getProcessorId()

Returns the processor identifier

Specified by:

getProcessorId in interface FeedMessageProcessor

Returns:

- the processor identifier

processMessage

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

Starts the processing pipeline by calling the firstProcessor

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

setNextMessageProcessor

public void setNextMessageProcessor(FeedMessageProcessor nextMessageProcessor)

This method should be ignored since the CompositeMessageProcessor is the trigger/starter of the processing pipeline and can't have a successor processor

Specified by:

setNextMessageProcessor in interface FeedMessageProcessor

Parameters:

nextMessageProcessor - - should be ignored/not used