X-Git-Url: http://git.nikiroo.be/?a=blobdiff_plain;f=src%2Fbe%2Fnikiroo%2Futils%2Fserial%2Fserver%2FServerObject.java;h=a6a5dd1b83573c3ca0814f7c409ae872d2061e59;hb=7ce18848c8327967ce27b90abf2e280953530b5f;hp=67dfa4a020d3a0cb8f8a70446298ddb7e0b0f7ee;hpb=0ff71477abf90d4843b8d9a3dc9907b5edc95fc0;p=nikiroo-utils.git

diff --git a/src/be/nikiroo/utils/serial/server/ServerObject.java b/src/be/nikiroo/utils/serial/server/ServerObject.java
deleted file mode 100644
index 67dfa4a..0000000
--- a/src/be/nikiroo/utils/serial/server/ServerObject.java
+++ /dev/null
@@ -1,100 +0,0 @@
-package be.nikiroo.utils.serial.server;
-
-import java.io.IOException;
-import java.net.Socket;
-
-import be.nikiroo.utils.Version;
-
-/**
- * This class implements a simple server that can listen for connections and
- * send/receive objects.
- * <p>
- * Note: this {@link ServerObject} has to be discarded after use (cannot be
- * started twice).
- * 
- * @author niki
- */
-abstract public class ServerObject extends Server {
-	/**
-	 * Create a new server that will start listening on the network when
-	 * {@link ServerObject#start()} is called.
-	 * 
-	 * @param port
-	 *            the port to listen on, or 0 to assign any unallocated port
-	 *            found (which can later on be queried via
-	 *            {@link ServerObject#getPort()}
-	 * @param ssl
-	 *            use a SSL connection (or not)
-	 * 
-	 * @throws IOException
-	 *             in case of I/O error
-	 */
-	public ServerObject(int port, boolean ssl) throws IOException {
-		super(port, ssl);
-	}
-
-	/**
-	 * Create a new server that will start listening on the network when
-	 * {@link ServerObject#start()} is called.
-	 * 
-	 * @param name
-	 *            the server name (only used for debug info and traces)
-	 * @param port
-	 *            the port to listen on
-	 * @param ssl
-	 *            use a SSL connection (or not)
-	 * 
-	 * @throws IOException
-	 *             in case of I/O error
-	 */
-	public ServerObject(String name, int port, boolean ssl) throws IOException {
-		super(name, port, ssl);
-	}
-
-	@Override
-	protected ConnectActionServer createConnectActionServer(Socket s) {
-		return new ConnectActionServerObject(s) {
-			@Override
-			public void action(Version clientVersion) throws Exception {
-				try {
-					for (Object data = rec(); true; data = rec()) {
-						Object rep = null;
-						try {
-							rep = onRequest(this, clientVersion, data);
-						} catch (Exception e) {
-							onError(e);
-						}
-						send(rep);
-					}
-				} catch (NullPointerException e) {
-					// Client has no data any more, we quit
-				}
-			}
-
-			@Override
-			protected void onError(Exception e) {
-				getTraceHandler().error(e);
-			}
-		};
-	}
-
-	/**
-	 * This is the method that is called on each client request.
-	 * <p>
-	 * You are expected to react to it and return an answer (which can be NULL).
-	 * 
-	 * @param action
-	 *            the client action
-	 * @param clientVersion
-	 *            the client version
-	 * @param data
-	 *            the data sent by the client (which can be NULL)
-	 * 
-	 * @return the answer to return to the client (which can be NULL)
-	 * 
-	 * @throws Exception
-	 *             in case of an exception, the error will only be logged
-	 */
-	abstract protected Object onRequest(ConnectActionServerObject action,
-			Version clientVersion, Object data) throws Exception;
-}