From eb16cf212c75c81b8714308c7848887447aee33f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Thu, 5 Apr 2012 13:28:06 +0200
Subject: Add RequestHandler.

---
 .../java/com/orbekk/protobuf/RequestHandler.java   | 32 ++++++++++++++++++++++
 1 file changed, 32 insertions(+)
 create mode 100644 src/main/java/com/orbekk/protobuf/RequestHandler.java

diff --git a/src/main/java/com/orbekk/protobuf/RequestHandler.java b/src/main/java/com/orbekk/protobuf/RequestHandler.java
new file mode 100644
index 0000000..0232a2c
--- /dev/null
+++ b/src/main/java/com/orbekk/protobuf/RequestHandler.java
@@ -0,0 +1,32 @@
+import java.util.concurrent.BlockingQueue;
+
+/**
+ * TODO: Move services to this class.
+ */
+
+public class RequestHandler extends Thread {
+    private volatile boolean isStopped = false;
+    private final BlockingQueue<Data.Request> input;
+    private final BlockingQueue<Data.Response> output;
+
+    public RequestHandler(BlockingQueue<Data.Request> input,
+            BlockingQueue<Data.Response> output) {
+        this.input = input;
+        this.output = output;
+    }
+
+    private void handleRequest() {
+
+    }
+
+    @Override public void run() {
+        while (!isStopped) {
+            handleRequest();
+        }
+    }
+
+    @Override public void interrupt() {
+        super.interrupt();
+        isStopped = true;
+    }
+}
-- 
cgit v1.2.3