import java.net.*;
import java.io.*;


public class MessageServer extends Thread implements Serializable {

  int port;
  private String message;
  private byte[] data;
  transient ServerSocket ss;
  

  public MessageServer() throws IOException {
    this("Hello", 3452);
  }
  
  public MessageServer(String message) throws IOException {
    this(message, 3452);
  }
  
  public MessageServer(String message, int port) throws IOException {
    this.message = message;
    data = message.getBytes();
    this.port = port;
    ss = new ServerSocket(port);
    start();
  }
  
  public void run() {
  
    try {
      if (ss == null) ss = new ServerSocket(port);
      while (true) {
        Socket s = ss.accept();
        OutputStream os = s.getOutputStream();
        os.write(data);
        s.close();
      }
    }
    catch (IOException e) {
    }
     
  }
  
  public synchronized void setMessage(String s) {
    this.message = message;
    data = message.getBytes();
  }
  
  public String getMessage(String s) {
    return message;
  }

  public int getPort(int port) {
    return port;
  }
  
}