From 0ed2c1124cf1b9e49a2ec1fa0126a8df09f9e758 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Tue, 7 Oct 2014 09:18:11 +0200
Subject: Repackage to org.cristalise

---
 .../com/c2kernel/entity/proxy/ProxyServer.java     | 128 ---------------------
 1 file changed, 128 deletions(-)
 delete mode 100644 src/main/java/com/c2kernel/entity/proxy/ProxyServer.java

(limited to 'src/main/java/com/c2kernel/entity/proxy/ProxyServer.java')

diff --git a/src/main/java/com/c2kernel/entity/proxy/ProxyServer.java b/src/main/java/com/c2kernel/entity/proxy/ProxyServer.java
deleted file mode 100644
index 25c2cd9..0000000
--- a/src/main/java/com/c2kernel/entity/proxy/ProxyServer.java
+++ /dev/null
@@ -1,128 +0,0 @@
-/**
- * This file is part of the CRISTAL-iSE kernel.
- * Copyright (c) 2001-2014 The CRISTAL Consortium. All rights reserved.
- *
- * This library is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as published
- * by the Free Software Foundation; either version 3 of the License, or (at
- * your option) any later version.
- *
- * This library is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; with out even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
- * License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this library; if not, write to the Free Software Foundation,
- * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
- *
- * http://www.fsf.org/licensing/licenses/lgpl.html
- */
-package com.c2kernel.entity.proxy;
-
-import java.util.ArrayList;
-import java.util.concurrent.LinkedBlockingQueue;
-
-import com.c2kernel.process.Gateway;
-import com.c2kernel.utils.Logger;
-import com.c2kernel.utils.server.SimpleTCPIPServer;
-
-public class ProxyServer implements Runnable {
-
-    // server objects
-    ArrayList<ProxyClientConnection> proxyClients;
-    SimpleTCPIPServer proxyListener = null;
-    String serverName = null;
-    boolean keepRunning = true;
-    LinkedBlockingQueue<ProxyMessage> messageQueue;
-    
-	public ProxyServer(String serverName) {
-        Logger.msg(5, "ProxyManager::initServer - Starting.....");
-        int port = Gateway.getProperties().getInt("ItemServer.Proxy.port", 0);
-        this.serverName = serverName;
-        this.proxyClients = new ArrayList<ProxyClientConnection>();
-        this.messageQueue = new LinkedBlockingQueue<ProxyMessage>();
-        
-        if (port == 0) {
-            Logger.error("ItemServer.Proxy.port not defined in connect file. Remote proxies will not be informed of changes.");
-            return;
-        }
-
-        // set up the proxy server
-        try {
-            Logger.msg(5, "ProxyManager::initServer - Initialising proxy informer on port "+port);
-            proxyListener = new SimpleTCPIPServer(port, ProxyClientConnection.class, 200);
-            proxyListener.startListening();
-        } catch (Exception ex) {
-            Logger.error("Error setting up Proxy Server. Remote proxies will not be informed of changes.");
-            Logger.error(ex);
-        }
-        // start the message queue delivery thread
-        new Thread(this).start();
-	}
-	
-	@Override
-	public void run() {
-		
-		while(keepRunning) {
-			ProxyMessage message = messageQueue.poll();
-			if (message != null) {
-	            synchronized(proxyClients) {
-	                for (ProxyClientConnection client : proxyClients) {
-	                    client.sendMessage(message);
-	                }
-	            }
-			} else
-				try {
-					synchronized(this) {
-						if (messageQueue.isEmpty()) wait(); 
-					}
-				} catch (InterruptedException e) { }
-		}
-
-	}
-
-	public String getServerName() {
-		return serverName;
-	}
-
-    public void sendProxyEvent(ProxyMessage message) {
-		try {
-			synchronized(this) { 
-				messageQueue.put(message);
-				notify(); 
-			}
-		} catch (InterruptedException e) { }
-    }
-
-    public void reportConnections(int logLevel) {
-        synchronized(proxyClients) {
-            Logger.msg(logLevel, "Currently connected proxy clients:");
-            for (ProxyClientConnection client : proxyClients) {
-                Logger.msg(logLevel, "   "+client);
-            }
-        }
-    }
-
-    public void shutdownServer() {
-        Logger.msg(1, "ProxyManager: Closing Server.");
-        proxyListener.stopListening();
-        synchronized(this) { 
-        	keepRunning = false; 
-        	notify();
-        }
-    }
-
-    public void registerProxyClient(ProxyClientConnection client) {
-        synchronized(proxyClients) {
-            proxyClients.add(client);
-        }
-    }
-
-    public void unRegisterProxyClient(ProxyClientConnection client) {
-        synchronized(proxyClients) {
-            proxyClients.remove(client);
-        }
-    }
-
-}
-- 
cgit v1.2.3