diff --git a/src/xyz/nextn/WorkerRunnable.java b/src/xyz/nextn/WorkerRunnable.java new file mode 100644 index 0000000..82b95ac --- /dev/null +++ b/src/xyz/nextn/WorkerRunnable.java @@ -0,0 +1,35 @@ +package xyz.nextn; + +import java.io.IOException; +import java.io.InputStream; +import java.io.OutputStream; +import java.net.Socket; + +public class WorkerRunnable implements Runnable{ + + protected Socket clientSocket = null; + protected String serverText = null; + + public WorkerRunnable(Socket clientSocket, String serverText) { + this.clientSocket = clientSocket; + this.serverText = serverText; + } + + public void run() { + try { + InputStream input = clientSocket.getInputStream(); + OutputStream output = clientSocket.getOutputStream(); + long time = System.currentTimeMillis(); + output.write(("HTTP/1.1 200 OK\n\nWorkerRunnable: " + + this.serverText + " - " + + time + + "").getBytes()); + output.close(); + input.close(); + System.out.println("Request processed: " + time); + } catch (IOException e) { + //report exception somewhere. + e.printStackTrace(); + } + } +}