package antLogger.testApps;

import java.io.*;
import antLogger.logServer.*;

/**
* TestMessageServer -
* Dies ist ein Test Message Server welche an Port 1235 auf Verbindungen hört.
* Alle Daten die Er erhält gibt er auf der Konsole aus.
*
* JAVA-Logger antLogger; Projekt der HTA Luzern->Abteilung Informatik->Software Engineering
* Authoren Patrick Bründler, Pascal Mengelt, Andy Wyss, Fabian Heusser
* Teacher: Jörg Hofstetter
* School: hta.fhz.ch, Horw;
* Project Homepage: http://www.w3p.ch/antLogger/
*
*
* LEGAL NOTICE
* THIS PROJECT AND ITS FILES ARE COPYRIGHTED BY THE AUTHORS
* THIS PROJECT CAN BE COPIED, MODIFIED AND DISTRIBUTED
* UNDER THE TERMS OF THE GNU GENERAL PUBLIC LICENCE
*
* @author Fabian Heusser
* @author Patrick Bründler
* @author Pascal Mengelt
* @author Andy Wyss
 * @version 1.0 $Date$ $Revision$
* @(#) TestMessageServer
*/

public class TestMessageServer {
private final int port = 1234;


//private BufferedReader input;
private InputStreamReader input;
  public TestMessageServer (){
    StreamCollector ms = new StreamCollector(port);
    System.out.println("System ready. Listening on Port " + port + "...");
    //input = new BufferedReader(new InputStreamReader(ms.getReadPipe()));
    input = new InputStreamReader(ms.getReadPipe());
    Thread t = new Thread(){
      public void run() {
        String s;
        try {for (;;){
            //while ((s = input.readLine()) != null){System.out.print(s);}  //funtioniert nicht da irgendwas falsches in die pipe kommt....
            while (input.ready()){System.out.print((char)input.read());}
            if (!input.ready()) sleep(1);
        }} catch (Exception ex) {ex.printStackTrace();}
    }};
    t.setPriority(t.MAX_PRIORITY);
    t.start();
  }


  public static void main(String[] args){
    new TestMessageServer();
  }
}