Package com.sportradar.livedata.sdk.proto

Class LiveFeedProtocol

java.lang.Object

com.sportradar.livedata.sdk.proto.common.ProtocolBase<IncomingMessage,OutgoingMessage>

com.sportradar.livedata.sdk.proto.LiveFeedProtocol

All Implemented Interfaces:

Protocol<IncomingMessage,OutgoingMessage>

public class LiveFeedProtocol
extends ProtocolBase<IncomingMessage,OutgoingMessage>

A Protocol implementation used to connect to the live-feed.

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.joda.time.Duration	DISCONNECT_WHEN_HAVING_TO_WAIT_LONGER_THAN	When having to wait longer than that amount of time for logging-in, just disconnect.

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

gateway, isStarted, listener, messageParser, sdkLogger

Constructor Summary

Constructors

Constructor	Description
LiveFeedProtocol(Gateway gateway, MessageParser<IncomingMessage> messageParser, MessageWriter<OutgoingMessage> messageWriter, RateLimiter rateLimiter, OutgoingMessageInspector<OutgoingMessage> outgoingMessageInspector, AuthMessageProvider authMessageProvider)	Initializes a new instance of the LiveFeedProtocol class.

Method Summary

Modifier and Type	Method	Description
protected void	notifyOnDisconnected()	Notifies the observer that the current LiveFeedProtocol has disconnected.
protected void	notifyOnLoggedIn()	Notifies the observer that the current LiveFeedProtocol has logged in.
protected void	onGatewayConnected()	Invoked by the observed Gateway instance when it establishes a connection to the server.
protected void	onGatewayDisconnected()	Invoked when the internally used Gateway drops connection to the remote host.
protected void	onMessageParsed(IncomingMessage message)	Invoked when the observed MessageParser parsed data which represented a whole message.
boolean	sendMessage(OutgoingMessage message, boolean blocking)	Sends the passed OutgoingMessage instance to the server.
void	sendMessage(String data)	Sends the passed data to the server as is.
void	stop()	Stops the protocol - i.e.

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

connect, isStarted, notifyOnEvent, notifyOnMessageReceived, onGatewayDataReceived, onGatewayError, reconnect, setDependencyListeners, setListener, start

Methods inherited from class java.lang.Object

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

Field Details

DISCONNECT_WHEN_HAVING_TO_WAIT_LONGER_THAN

protected final org.joda.time.Duration DISCONNECT_WHEN_HAVING_TO_WAIT_LONGER_THAN

When having to wait longer than that amount of time for logging-in, just disconnect.

Constructor Details

LiveFeedProtocol

public LiveFeedProtocol(Gateway gateway,
 MessageParser<IncomingMessage> messageParser,
 MessageWriter<OutgoingMessage> messageWriter,
 RateLimiter rateLimiter,
 OutgoingMessageInspector<OutgoingMessage> outgoingMessageInspector,
 AuthMessageProvider authMessageProvider)

Initializes a new instance of the LiveFeedProtocol class.

Parameters:

gateway - The Gateway implementation used to establish a connection to the live-odds server.

messageParser - The MessageParser implementation used to construct IncomingMessage instances from data received from the server.

messageWriter - The used to write messages to byte[].

rateLimiter - The RateLimiter implementation used to rate-limit send messages

outgoingMessageInspector - The OutgoingMessageInspector implementation used to inspect send messages.

authMessageProvider - The provider of authentication messages such as login and logout.

Method Details

sendMessage

public boolean sendMessage(OutgoingMessage message,
 boolean blocking)
                    throws MessageException,
ProtocolException

Sends the passed OutgoingMessage instance to the server.

Parameters:

message - The message derived from OutgoingMessage to be send to the server.

blocking - true if request must be blocking.

Returns:

true if success.

Throws:

MessageException - An error occurred while writing the message to byte array.

ProtocolException - thrown when an un-expected situation is encountered.

sendMessage

public void sendMessage(String data)
                 throws MessageException,
ProtocolException

Sends the passed data to the server as is.

Parameters:

data - data to be sent.

Throws:

MessageException - An error occurred while writing the message to byte array.

ProtocolException - thrown when an un-expected situation is encountered.

stop

public void stop()

Stops the protocol - i.e. disables the communication with the server.

Specified by:

stop in interface Protocol<IncomingMessage,OutgoingMessage>

Overrides:

stop in class ProtocolBase<IncomingMessage,OutgoingMessage>

onGatewayConnected

protected void onGatewayConnected()

Invoked by the observed Gateway instance when it establishes a connection to the server.

Overrides:

onGatewayConnected in class ProtocolBase<IncomingMessage,OutgoingMessage>

onGatewayDisconnected

protected void onGatewayDisconnected()

Invoked when the internally used Gateway drops connection to the remote host.

Overrides:

onGatewayDisconnected in class ProtocolBase<IncomingMessage,OutgoingMessage>

onMessageParsed

protected void onMessageParsed(IncomingMessage message)

Invoked when the observed MessageParser parsed data which represented a whole message.

Overrides:

onMessageParsed in class ProtocolBase<IncomingMessage,OutgoingMessage>

Parameters:

message - Message constructed from the received data.

notifyOnDisconnected

protected void notifyOnDisconnected()

Notifies the observer that the current LiveFeedProtocol has disconnected.

notifyOnLoggedIn

protected void notifyOnLoggedIn()

Notifies the observer that the current LiveFeedProtocol has logged in.