Package com.sportradar.livedata.sdk.feed.common

Class MessagePipeline<T extends LiveScoutEntityBase>

java.lang.Object

com.sportradar.livedata.sdk.feed.common.MessagePipeline<T>

All Implemented Interfaces:

MessageProcessor<T>

public class MessagePipeline<T extends LiveScoutEntityBase>
extends Object
implements MessageProcessor<T>

A message - processing pipeline which consists of multiple MessageProcessor instances. Each message processor can, after processing the message hand it to the next processor, or can stop the processing of the current message.

Author:

uros.bregar

Constructor Summary

Constructors

Constructor	Description
MessagePipeline(int index, MessageProcessor<T>... processors)	Initializes a new instance of the MessagePipeline class from the passed MessageProcessor instances.

Method Summary

Modifier and Type	Method	Description
int	getIndex()	Gets the index of the current MessageProcessor implementation used to determine the correct order of message processors when there are multiple message processors processing the same message.
void	processMessage(T message)	Processes the passed message derived from LiveScoutEntityBase class.
void	setListener(MessageProcessorListener<T> listener)	Sets the MessageProcessorListener instance used to observe the current MessageProcessor

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagePipeline

@SafeVarargs
public MessagePipeline(int index,
                       MessageProcessor<T>... processors)

Initializes a new instance of the MessagePipeline class from the passed MessageProcessor instances.

Parameters:

index - the index of the current MessageProcessor implementation

processors - the MessageProcessor instances from which the pipeline will be composed.

Method Detail

getIndex

public int getIndex()

Gets the index of the current MessageProcessor implementation used to determine the correct order of message processors when there are multiple message processors processing the same message.

Specified by:

getIndex in interface MessageProcessor<T extends LiveScoutEntityBase>

Returns:

the index of the current MessageProcessor implementation

processMessage

public void processMessage(T message)

Processes the passed message derived from LiveScoutEntityBase class.

Specified by:

processMessage in interface MessageProcessor<T extends LiveScoutEntityBase>

Parameters:

message - The LiveScoutEntityBase derived class representing the message.

Throws:

IllegalArgumentException - the message is a null reference.

setListener

public void setListener(MessageProcessorListener<T> listener)

Sets the MessageProcessorListener instance used to observe the current MessageProcessor

Specified by:

setListener in interface MessageProcessor<T extends LiveScoutEntityBase>

Parameters:

listener - The MessageProcessorListener used to observe the processor.