diff options
Diffstat (limited to 'src/main/java/com/orbekk/protobuf/RequestHandler.java')
-rw-r--r-- | src/main/java/com/orbekk/protobuf/RequestHandler.java | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/src/main/java/com/orbekk/protobuf/RequestHandler.java b/src/main/java/com/orbekk/protobuf/RequestHandler.java deleted file mode 100644 index 0232a2c..0000000 --- a/src/main/java/com/orbekk/protobuf/RequestHandler.java +++ /dev/null @@ -1,32 +0,0 @@ -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; - } -} |