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 trough the message processing pipeline

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

CompositeMessageProcessor

public CompositeMessageProcessor(List<FeedMessageProcessor> processors)

Constructs a new CompositeMessageProcessor instance

Parameters:

processors - - a completeList pipeline processors

Method Detail

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