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

Class LiveFeedProtocolManager

java.lang.Object

com.sportradar.livedata.sdk.feed.common.LiveFeedProtocolManager

All Implemented Interfaces:

ProtocolManager<OutgoingMessage,LiveScoutEntityBase>

public class LiveFeedProtocolManager
extends Object
implements ProtocolManager<OutgoingMessage,LiveScoutEntityBase>

A ProtocolManager implementation used to manage protocol which connects to a live-feed

Field Summary

Fields

Modifier and Type	Field	Description
protected SdkLogger	sdklogger	The SdkLogger implementation used for structured logging.

Constructor Summary

Constructors

Constructor	Description
LiveFeedProtocolManager(Protocol<IncomingMessage,OutgoingMessage> protocol, EntityMapper<IncomingMessage,LiveScoutEntityBase> entityMapper, MessageProcessor<LiveScoutEntityBase> messageProcessor, RequestProducer<OutgoingMessage> requestProducer)	Initializes a new instance of the LiveFeedProtocolManager class

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the underlying protocol
protected void	notifyOnDisconnected()	Notifies the observer that the connection to the server was dropped.
protected final void	notifyOnLoggedIn()	Notifies the observer that the protocol has successfully logged in to the server.
protected final void	notifyOnMessageReceived(LiveScoutEntityBase message)	Notifies the observer that new message was received.
void	open()	Opens the underlying protocol
protected void	processMessage(IncomingMessage message)	Processes the received message
void	reconnect()	Reconnects the underlying feed
protected boolean	sendMessage(OutgoingMessage message, boolean blocking)	Sends the passed OutgoingMessage instance to the server.
void	sendMessage(String data)	Sends the passed string representation of the message to the server.
void	setListener(ProtocolManagerListener<LiveScoutEntityBase> listener)	Sets the listener used to observe the current ProtocolManager.

Methods inherited from class java.lang.Object

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

Field Details

sdklogger

protected SdkLogger sdklogger

The SdkLogger implementation used for structured logging.

Constructor Details

LiveFeedProtocolManager

public LiveFeedProtocolManager(Protocol<IncomingMessage,OutgoingMessage> protocol,
 EntityMapper<IncomingMessage,LiveScoutEntityBase> entityMapper,
 MessageProcessor<LiveScoutEntityBase> messageProcessor,
 RequestProducer<OutgoingMessage> requestProducer)

Initializes a new instance of the LiveFeedProtocolManager class

Parameters:

protocol - The Protocol implementation used to communicate with the target feed.

entityMapper - The EntityMapper implementation used to map received messages to feed entities.

messageProcessor - The MessageProcessor used to process incoming messages

requestProducer - The RequestProducer implementation which produces message to be send to the server.

Method Details

close

public void close()

Closes the underlying protocol

Specified by:

close in interface ProtocolManager<OutgoingMessage,LiveScoutEntityBase>

open

public void open()

Opens the underlying protocol

Specified by:

open in interface ProtocolManager<OutgoingMessage,LiveScoutEntityBase>

reconnect

public void reconnect()

Description copied from interface: ProtocolManager

Reconnects the underlying feed

Specified by:

reconnect in interface ProtocolManager<OutgoingMessage,LiveScoutEntityBase>

sendMessage

public void sendMessage(String data)

Sends the passed string representation of the message to the server.

Specified by:

sendMessage in interface ProtocolManager<OutgoingMessage,LiveScoutEntityBase>

Parameters:

data - - The String to be send to the server.

setListener

public void setListener(ProtocolManagerListener<LiveScoutEntityBase> listener)

Sets the listener used to observe the current ProtocolManager.

Specified by:

setListener in interface ProtocolManager<OutgoingMessage,LiveScoutEntityBase>

Parameters:

listener - The ProtocolManagerListener used to observe the ProtocolManager

notifyOnDisconnected

protected void notifyOnDisconnected()

Notifies the observer that the connection to the server was dropped.

notifyOnLoggedIn

protected final void notifyOnLoggedIn()

Notifies the observer that the protocol has successfully logged in to the server.

notifyOnMessageReceived

protected final void notifyOnMessageReceived(LiveScoutEntityBase message)

Notifies the observer that new message was received.

Parameters:

message - The LiveScoutEntityBase derived instance representing the received message.

processMessage

protected void processMessage(IncomingMessage message)

Processes the received message

Parameters:

message - The IncomingMessage representing the received message.

sendMessage

protected boolean sendMessage(OutgoingMessage message,
 boolean blocking)

Sends the passed OutgoingMessage instance to the server.

Parameters:

message - the OutgoingMessage instance to be send to the server.

blocking - mark if request must be blocking.

Returns:

true if success.

Throws:

IllegalArgumentException - the message is a null reference.

IllegalStateException - the message cannot be send at this time.