package com.modbus.data;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.net.Socket;
|
import com.serotonin.modbus4j.serial.SerialPortWrapper;
|
|
public class SerialPortWrapperImpl implements SerialPortWrapper{
|
private Socket socket;
|
|
public SerialPortWrapperImpl(Socket socket){
|
this.socket = socket;
|
}
|
|
@Override
|
public void close() throws Exception {
|
if(null != socket) {
|
this.socket.close();
|
}
|
}
|
|
@Override
|
public int getBaudRate() {
|
return 0;
|
}
|
|
@Override
|
public int getDataBits() {
|
return 0;
|
}
|
|
@Override
|
public int getFlowControlIn() {
|
return 0;
|
}
|
|
@Override
|
public int getFlowControlOut() {
|
return 0;
|
}
|
|
@Override
|
public InputStream getInputStream() {
|
if(null != socket) {
|
try {
|
return socket.getInputStream();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public OutputStream getOutputStream() {
|
if(null != socket) {
|
try {
|
return socket.getOutputStream();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public int getParity() {
|
return 0;
|
}
|
|
@Override
|
public int getStopBits() {
|
return 0;
|
}
|
|
@Override
|
public void open() throws Exception {
|
|
}
|
|
|
public static void main(String[] args) {
|
//SerialPortWrapperImpl impl = new SerialPortWrapperImpl(new Socket());
|
}
|
}
|