dataTransmitter

Class DataTransmitter

java.lang.Object

dataTransmitter.DataTransmitter

All Implemented Interfaces:

java.lang.Runnable

public class DataTransmitter
extends java.lang.Object
implements java.lang.Runnable

The class DataTransmitter is responsible for scheduling transfer of flow databases (FDB files) to the server.
It is intended to run in its own thread.

Author:

Jacob Honoré Broberg, Kartheepan Balachandran (kba@es.aau.dk), Tomasz Bujlow (tbu@es.aau.dk)

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	clientId Identifier of the client.
private java.lang.Thread	dataTransmitterThread Thread used by this class.
private java.lang.String	defaultFDBdirectory Directory containing FDB files, which should be transferred to the server.
private boolean	isStarted Flag used to determine if the thread is fully started.
private static org.apache.log4j.Logger	log Used to log different events.
private FileTransferClient	myTransferClient Object responsible for transferring a particular file to the server.
private boolean	runFlag Flag used to stop the thread.
private int	serverFileTransmitPort TCP port on the server on which the file transmission occurs.
private java.lang.String	serverIP IP address of the server.

Constructor Summary

Constructors

Constructor and Description
DataTransmitter(java.lang.String defaultFDBdirectory) Constructs the object.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isAlive() Checks if DataTransmitter is alive.
private boolean	isConfigured() Creates new instance of class responsible for transferring a particular file to the server.
void	run() Loops and transfers all unsent flow record files to the server.
void	setClientId(java.lang.String clientId) Sets the identifier of the client.
void	setServerFileTransmitPort(int serverFileTransmitPort) Sets TCP port on the server on which the file transmission occurs.
void	setServerIP(java.lang.String serverIP) Sets IP address of the server.
void	start() Starts the thread.
void	stop() Stops the thread.
private void	transmitUnsentFiles() Transmits all flow databases (FDB files) to the server.

Methods inherited from class java.lang.Object

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

Field Detail

log

private static org.apache.log4j.Logger log

Used to log different events.

dataTransmitterThread

private java.lang.Thread dataTransmitterThread

Thread used by this class.

clientId

private java.lang.String clientId

Identifier of the client. It will be transferred to the server before any file transfer can occur.

myTransferClient

private FileTransferClient myTransferClient

Object responsible for transferring a particular file to the server.

serverIP

private java.lang.String serverIP

IP address of the server.

serverFileTransmitPort

private int serverFileTransmitPort

TCP port on the server on which the file transmission occurs.

runFlag

private boolean runFlag

Flag used to stop the thread.

isStarted

private boolean isStarted

Flag used to determine if the thread is fully started.

defaultFDBdirectory

private java.lang.String defaultFDBdirectory

Directory containing FDB files, which should be transferred to the server.

Constructor Detail

DataTransmitter

public DataTransmitter(java.lang.String defaultFDBdirectory)

Constructs the object.

Parameters:

defaultFDBdirectory - directory containing FDB files, which should be transferred to the server

Method Detail

start

public void start()

Starts the thread.

stop

public void stop()

Stops the thread.

isAlive

public boolean isAlive()

Checks if DataTransmitter is alive. It means that:
- the thread must exists
- the thread must be fully started and running (isStarted equals true). This condition is used to check if the thread is fully started or if it needs more time to start.

Returns:

true if the thread is fully started and operational, false otherwise

run

public void run()

Loops and transfers all unsent flow record files to the server.

Specified by:

run in interface java.lang.Runnable

isConfigured

private boolean isConfigured()

Creates new instance of class responsible for transferring a particular file to the server.

Returns:

true if the instance was created, false otherwise

setClientId

public void setClientId(java.lang.String clientId)

Sets the identifier of the client.

Parameters:

clientId - identifier of the client

setServerIP

public void setServerIP(java.lang.String serverIP)

Sets IP address of the server.

Parameters:

serverIP - IP address of the server

setServerFileTransmitPort

public void setServerFileTransmitPort(int serverFileTransmitPort)

Sets TCP port on the server on which the file transmission occurs.

Parameters:

serverFileTransmitPort - TCP port on the server for file transmissions

transmitUnsentFiles

private void transmitUnsentFiles()

Transmits all flow databases (FDB files) to the server.