Package com.sportradar.livedata.sdk.proto.common

Class IncrementalMessageTokenizer

java.lang.Object

com.sportradar.livedata.sdk.proto.common.MessageTokenizerBase

com.sportradar.livedata.sdk.proto.common.IncrementalMessageTokenizer

All Implemented Interfaces:

MessageTokenizer

public class IncrementalMessageTokenizer
extends MessageTokenizerBase

Represents a tokenizer where data arrives in chunks. Contains logic for low-level byte splitting.

Author:

uros.bregar

Field Summary

Fields

Modifier and Type	Field	Description
static Charset	ENCODING	The name of the used encoding

Fields inherited from class com.sportradar.livedata.sdk.proto.common.MessageTokenizerBase

listener

Constructor Summary

Constructors

Constructor	Description
IncrementalMessageTokenizer(int bufferSize)	Initializes a new instance of the IncrementalMessageTokenizer class.

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears and temporary data stored in the tokenizer.
protected int	findElementEnd(byte[] source, byte[] elementName, int offset, int maxIndex)	Finds the index of the first occurrence of bytes representing the end of the element in the source.
protected static int	indexOf(byte[] source, byte[] pattern, int offset, int maxIndex)	Finds the index of the first occurrence of bytes specified by the pattern in source.
void	processData(InputStream stream)	Processes passed data.
protected static int	selectIndex(int index1, int index2)	returns the index which is smaller but is not equal to -1.

Methods inherited from class com.sportradar.livedata.sdk.proto.common.MessageTokenizerBase

notifyListener, setListener

Methods inherited from class java.lang.Object

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

Field Detail

ENCODING

public static final Charset ENCODING

The name of the used encoding

Constructor Detail

IncrementalMessageTokenizer

public IncrementalMessageTokenizer(int bufferSize)

Initializes a new instance of the IncrementalMessageTokenizer class.

Parameters:

bufferSize - the size of the internal buffer used to store incomplete messages

Throws:

IllegalArgumentException - the bufferSize is smaller than or equal to 0.

Method Detail

clear

public void clear()

Clears and temporary data stored in the tokenizer.

processData

public void processData(InputStream stream)
                 throws SdkException

Processes passed data. If passed data and any previously stored data represent a whole message the MessageTokenizerListener.onMessageReady(byte[]) method is invoked

Specified by:

processData in interface MessageTokenizer

Specified by:

processData in class MessageTokenizerBase

Parameters:

stream - A InputStream containing data to be tokenized.

Throws:

IllegalArgumentException - the stream is a null reference.

ProtocolException - the data could not be processed either because the buffer is full

ProtocolException - the data could not be processed either because the buffer is full, an un-expected character was encountered or there was an error while un-marshalling the message

SdkException

findElementEnd

protected int findElementEnd(byte[] source,
                             byte[] elementName,
                             int offset,
                             int maxIndex)

Finds the index of the first occurrence of bytes representing the end of the element in the source. The end of the element can be specified in a normal format '@lt;/elementName>' or the shorten one (/>) but must be followed by double LF/CR combination. The search starts at the location specified by the offset. The returned index points to the '>' character.

Parameters:

source - the array to be searched

elementName - the byte array representation of the element's name

offset - offset the index specifying where in the source array to begin the search.

maxIndex - specifies the maximum source index to be included in the search.

Returns:

The index of the first occurrence or -1 if the MESSAGE_END does not exist in the source.

indexOf

protected static int indexOf(byte[] source,
                             byte[] pattern,
                             int offset,
                             int maxIndex)

Finds the index of the first occurrence of bytes specified by the pattern in source. The search starts at the location specified by the offset. The returned index points to the first byte of the searched sequence.

Parameters:

source - the source of the search

pattern - the bytes to be found in the source.

offset - the index specifying where in the source array to begin the search.

maxIndex - specifies the maximum source index to be included in the search.

Returns:

The index of the first occurrence or -1 if the pattern does not exist in the source.

selectIndex

protected static int selectIndex(int index1,
                                 int index2)

returns the index which is smaller but is not equal to -1. If both indexes are equal to -1, than -1 is returned.

Parameters:

index1 - the first index.

index2 - the second index

Returns:

the index which is smaller but is not equal to -1. If both indexes are equal to -1, than -1 is returned.