Notes

package tr.com.solvia.weigherbridge;

import com.alexkasko.installer.DaemonLauncher;
import com.fazecast.jSerialComm.SerialPort;
import tr.com.solvia.weigherbridge.propertiesfile.PropertiesKey;
import tr.com.solvia.weigherbridge.serialport.SerialPortAlgorithm;
import tr.com.solvia.weigherbridge.serialport.impl.SerialPortAlgorithmImpl;
import tr.com.solvia.weigherbridge.socket.SocketAlgorithm;
import tr.com.solvia.weigherbridge.socket.impl.SocketAlgorithmImpl;

import java.io.IOException;

public class MyApplication implements DaemonLauncher {
private SocketAlgorithm socketAlgorithm;
private SerialPortAlgorithm serialPortAlgorithm;
PropertiesKey propertiesKey = new PropertiesKey();

public MyApplication() {
super();
}

public void initialize() throws IOException, InterruptedException{
ThreadServer threadServer = new ThreadServer();
ThreadClient threadClient = new ThreadClient();
ThreadSerial threadSerial = new ThreadSerial();
ThreadSocketStart threadSocketStart = new ThreadSocketStart();
threadServer.start();
Thread.sleep(100);
threadSocketStart.start();
threadClient.start();
Thread.sleep(10);
threadSerial.start();
}

public void stop() throws IOException, InterruptedException{
ThreadServer threadServer = new ThreadServer();
ThreadClient threadClient = new ThreadClient();
ThreadSerial threadSerial = new ThreadSerial();
threadServer.stop();
threadClient.stop();
threadSerial.stop();
}

public void startDaemon() {
try {
initialize();
} catch (IOException e) {e.printStackTrace();
} catch (InterruptedException e) {e.printStackTrace();}
}

public void stopDaemon() {
try {
stop();
} catch (IOException e) {e.printStackTrace();
} catch (InterruptedException e) {e.printStackTrace();}
}

class ThreadServer extends Thread{
public void run(){
try {
socketAlgorithm = new SocketAlgorithmImpl();
socketAlgorithm.socketServer("Server is connected", propertiesKey.getSocketPort());
} catch (IOException e) {e.printStackTrace();}
}
}

class ThreadClient extends Thread{
public void run(){
try {
socketAlgorithm = new SocketAlgorithmImpl();
socketAlgorithm.socketClient("Client is connected", propertiesKey.getSocketPort());
} catch (IOException e) {e.printStackTrace();}
}
}

class ThreadSerial extends Thread{
public void run(){
serialPortAlgorithm = new SerialPortAlgorithmImpl();
serialPortAlgorithm.listeningPort("COM1",9600,8,1, SerialPort.NO_PARITY);
// serialPortAlgorithm.listeningPort(propertiesKey.getPortName(),propertiesKey.getBaudRate(),
// propertiesKey.getDataBits(),propertiesKey.getNewParity(),propertiesKey.getStopBits());
}
}

class ThreadSocketStart extends Thread{
public void run(){
try {
socketAlgorithm = new SocketAlgorithmImpl();
socketAlgorithm.startSocketServer(2203);
} catch (IOException e) {e.printStackTrace();}
}
}
}