import java.io.InputStream;
import java.io.OutputStream;

import gnu.io.CommPort;
import gnu.io.CommPortIdentifier;
import gnu.io.SerialPort;

public class Serial {
	
	public Serial() {
		super();
	}
	
	void connect(String portName) throws Exception {
		
		CommPortIdentifier portIndentifier = CommPortIdentifier.getPortIdentifier(portName);
		
		if (portIndentifier.isCurrentlyOwned()) {
			
			System.out.println("Error : Port is currently in use");
		} else {
			
			CommPort commPort = portIndentifier.open(this.getClass().getName(), 2000);
			
			if (commPort instanceof SerialPort) {
				
				SerialPort serialPort = (SerialPort) commPort;
				serialPort.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
				
				InputStream in = serialPort.getInputStream();
				OutputStream out = serialPort.getOutputStream();
				
				(new Thread(new SerialReader(in))).start();
				(new Thread(new SerialWriter(out))).start();
			} else {
				
				System.out.println("Error : Only serial ports are handled by this example");
			}
		}
	}
}