From c2209f62e635071ff02096b665e9fb4608beba73 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Fri, 13 Jan 2012 10:19:40 +0100
Subject: Refactoring.
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Rename com.orbekk.{rpc → same}.
---
 same/src/main/java/com/orbekk/rpc/RpcHandler.java | 52 -----------------------
 1 file changed, 52 deletions(-)
 delete mode 100644 same/src/main/java/com/orbekk/rpc/RpcHandler.java

(limited to 'same/src/main/java/com/orbekk/rpc/RpcHandler.java')

diff --git a/same/src/main/java/com/orbekk/rpc/RpcHandler.java b/same/src/main/java/com/orbekk/rpc/RpcHandler.java
deleted file mode 100644
index 0bafad4..0000000
--- a/same/src/main/java/com/orbekk/rpc/RpcHandler.java
+++ /dev/null
@@ -1,52 +0,0 @@
-package com.orbekk.rpc;
-
-import com.googlecode.jsonrpc4j.JsonRpcServer;
-import com.orbekk.net.HttpUtil;
-import com.orbekk.same.UrlReceiver;
-import java.io.IOException;
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import org.eclipse.jetty.server.Request;
-import org.eclipse.jetty.server.handler.AbstractHandler;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class RpcHandler extends AbstractHandler {
-    private Logger logger = LoggerFactory.getLogger(getClass());
-    private JsonRpcServer rpcServer;
-    private UrlReceiver urlReceiver;
-    
-    public RpcHandler(JsonRpcServer rpcServer,
-            UrlReceiver urlReceiver) {
-        this.rpcServer = rpcServer;
-        this.urlReceiver = urlReceiver;
-    }
-    
-    @Override
-    public synchronized void handle(String target, Request baseRequest,
-            HttpServletRequest request, HttpServletResponse response)
-            throws IOException, ServletException {
-        logger.info("Handling request to target: " + target);
-
-        if (urlReceiver != null) {
-            String sameServiceUrl = "http://" + request.getLocalAddr() + 
-                ":" + request.getLocalPort() + "/SameService.json";
-            urlReceiver.setUrl(sameServiceUrl);
-            urlReceiver = null;
-        }
-
-        if (target.equals("/ping")) {
-            int remotePort = Integer.parseInt(request.getParameter("port"));
-            String pongUrl = "http://" + request.getRemoteAddr() + ":" +
-                remotePort + "/pong";
-            logger.info("Got ping. Sending pong to {}", pongUrl);
-            HttpUtil.sendHttpRequest(pongUrl);
-        } else if (target.equals("/pong")) {
-            logger.info("Received pong from {}", request.getRemoteAddr());
-        } else {
-            rpcServer.handle(request, response);
-        }
-        baseRequest.setHandled(true);
-    }
-}
-- 
cgit v1.2.3