Package com.sportradar.livedata.sdk.common.networking

Class TcpGateway

java.lang.Object

com.sportradar.livedata.sdk.common.networking.TcpGateway

All Implemented Interfaces:

Gateway

public class TcpGateway
extends Object
implements Gateway

A Gateway implementation which uses TCP protocol stack to communicate.

Author:

uros.bregar

Constructor Summary

Constructors

Constructor	Description
TcpGateway(ExecutorService executor, SocketFactory socketFactory, InetSocketAddress endpoint, int bufferSize)	Initializes a new instance of the TcpGateway class.

Method Summary

Modifier and Type	Method	Description
void	connect()	Attempts to establish a connection to the remote site.
void	disconnect(boolean dueToError)	Drops the established connection.
String	getId()	Gets gateway id (hostname, port, ...)
long	getLastReceivedMsgTimestamp()	Gets last timestamp in unix millis when the last msg was received
boolean	isConnected()	Gets a value specifying whether the connection to the remote site is established.
void	sendData(byte[] data)	Sends data through the current Gateway.
void	setListener(GatewayListener listener)	Sets the GatewayListener used to observe the current Gateway implementation.

Methods inherited from class java.lang.Object

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

Constructor Details

TcpGateway

public TcpGateway(ExecutorService executor,
 SocketFactory socketFactory,
 InetSocketAddress endpoint,
 int bufferSize)

Initializes a new instance of the TcpGateway class.

Parameters:

executor - The ExecutorService instance used to execute tasks.

socketFactory - The SocketFactory instance used to build the Socket

endpoint - The InetSocketAddress instance specifying the remote endpoint of the socket.

bufferSize - The size of the read buffer in bytes

Throws:

IllegalArgumentException - The executor is a null reference or socketFactory is a null reference or endpoint is a null reference or bufferSize is smaller than zero.

Method Details

setListener

public void setListener(GatewayListener listener)

Sets the GatewayListener used to observe the current Gateway implementation.

Specified by:

setListener in interface Gateway

Parameters:

listener - the GatewayListener used to observe the current Gateway implementation or a null reference if observation is not required.

sendData

public void sendData(byte[] data)
              throws IOException

Sends data through the current Gateway.

Specified by:

sendData in interface Gateway

Parameters:

data - data to send.

Throws:

IllegalArgumentException - The data is a null reference or an empty array

IOException - connection problem

connect

public void connect()
             throws IOException

Attempts to establish a connection to the remote site.

Specified by:

connect in interface Gateway

Throws:

IOException - There was an error establishing the connection.

disconnect

public void disconnect(boolean dueToError)

Drops the established connection.

Specified by:

disconnect in interface Gateway

Parameters:

dueToError - - when false user wished to close connection; when true there was a problem and we had to close it

isConnected

public boolean isConnected()

Gets a value specifying whether the connection to the remote site is established.

Specified by:

isConnected in interface Gateway

Returns:

Value specifying whether the connection to the remote site is established.

getLastReceivedMsgTimestamp

public long getLastReceivedMsgTimestamp()

Gets last timestamp in unix millis when the last msg was received

Specified by:

getLastReceivedMsgTimestamp in interface Gateway

Returns:

timestamp when the last msg was received

getId

public String getId()

Description copied from interface: Gateway

Gets gateway id (hostname, port, ...)

Specified by:

getId in interface Gateway

Returns:

gateway identification