@@ -0,0 +1,723 @@
+import java.util.concurrent.BlockingQueue;%0A%0A/**%0A * TODO: Move services to this class.%0A */%0A%0Apublic class RequestHandler extends Thread %7B%0A    private volatile boolean isStopped = false;%0A    private final BlockingQueue%3CData.Request%3E input;%0A    private final BlockingQueue%3CData.Response%3E output;%0A%0A    public RequestHandler(BlockingQueue%3CData.Request%3E input,%0A            BlockingQueue%3CData.Response%3E output) %7B%0A        this.input = input;%0A        this.output = output;%0A    %7D%0A%0A    private void handleRequest() %7B%0A%0A    %7D%0A%0A    @Override public void run() %7B%0A        while (!isStopped) %7B%0A            handleRequest();%0A        %7D%0A    %7D%0A%0A    @Override public void interrupt() %7B%0A        super.interrupt();%0A        isStopped = true;%0A    %7D%0A%7D%0A

Add RequestHandler.