Source code: proxy/bearer/http/ConnectionListener.java

   package proxy.bearer.http;
   
   import java.io.*;
   import java.lang.*;
   import java.net.*;
   
   
   /**
    * <p>
   * Represents thread waiting for connection and serving them.
   * @deprecated Use Worker instead.
   *</p>
   */
  public class ConnectionListener extends Thread{
    private static final int MYPORT=9876;
  
    private ServerSocket myServerSocket;
  
  
    /**
     * <p>
     * Constructor.
     * </p>
     */
    public ConnectionListener(){
      super("ConnectionListener");
      try{
        myServerSocket=new ServerSocket(MYPORT);
      }catch(IOException e){
        System.out.println("Couldn't make server socket");
        System.exit(1);
      }
    }
  
  
    public void run(){
      Socket theClientSocket;
      while (true) {
        try {
          //to trzeba zrobic chyba jakos tak
  //        theClientSocket = myServerSocket.setSocketFactory();
          theClientSocket = myServerSocket.accept();
          PrintWriter theWriter = new PrintWriter(
              new OutputStreamWriter(theClientSocket.getOutputStream())
              );
          BufferedReader theReader = new BufferedReader(
              new InputStreamReader(theClientSocket.getInputStream())
              );
          theWriter.println("jak moge pomoc?");
          theWriter.flush();
  
          while (true){
            System.out.println(theReader.readLine());
          }
  
        }
        catch (IOException e) {
        }
      }
    }
  
  };