1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 |
- package at.acdp.urweb;
- import at.acdp.urweb.sclient.SecondaryClient;
- import at.acdp.urweb.sclient.URLog;
- import at.acdp.urweb.sclient.data.Message;
- import at.acdp.urweb.sclient.data.VersionMessage;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import java.io.IOException;
- public class ScReadThread implements Runnable {
- private static final Logger log = LoggerFactory.getLogger(SecondaryClient.class);
- private final String ip;
- SecondaryClient rde;
- ScReadThread(String ip) {
- this.ip=ip;
- }
- @Override
- public void run() {
- while(true) {
- try {
- read();
- } catch (IOException e) {
- log.warn("read thread terminated", e);
- URLog.add(new Message("read thread terminated", e ));
- }
- }
- }
- private void read() throws IOException {
- rde=new SecondaryClient(ip, 30002);
- VersionMessage vm = rde.connect();
- while(true) {
- rde.readPackage();
- }
- }
- public void writeCmd(String s) {
- log.info("writecmd: "+s);
- rde.writeCmd(s);
- }
- }
|