1 files changed, 0 insertions, 129 deletions
diff --git a/branches/pre-spec-changes/test/src/main/java/org/apache/tuscany/test/binding/TestSocketBindingServiceBinding.java b/branches/pre-spec-changes/test/src/main/java/org/apache/tuscany/test/binding/TestSocketBindingServiceBinding.java
deleted file mode 100644
index a1531b6f5f..0000000000
--- a/branches/pre-spec-changes/test/src/main/java/org/apache/tuscany/test/binding/TestSocketBindingServiceBinding.java
+++ /dev/null
@@ -1,129 +0,0 @@
-package org.apache.tuscany.test.binding;
-
-import java.io.IOException;
-import java.io.ObjectInputStream;
-import java.io.ObjectOutputStream;
-import java.net.ServerSocket;
-import java.net.Socket;
-import java.util.Map;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-import javax.xml.namespace.QName;
-
-import org.osoa.sca.Version;
-
-import org.apache.tuscany.spi.CoreRuntimeException;
-import org.apache.tuscany.spi.component.CompositeComponent;
-import org.apache.tuscany.spi.extension.ServiceBindingExtension;
-import org.apache.tuscany.spi.model.Operation;
-import org.apache.tuscany.spi.wire.InboundInvocationChain;
-import org.apache.tuscany.spi.wire.Message;
-import org.apache.tuscany.spi.wire.MessageImpl;
-
-/**
- * Implements a very simple remote, socket-based binding for test purposes. This binding exposes serviceBindings using a socket
- * on a given port. Service operations must take only one paramter that is <code>Serializable</code>.
- *
- * @version $Rev$ $Date$
- */
-public class TestSocketBindingServiceBinding extends ServiceBindingExtension {
-    private static final QName BINDING_TEST = new QName(Version.XML_NAMESPACE_1_0, "binding.socket");
-    private int port;
-    private ServerSocket socket;
-    private ExecutorService executor;
-    private TestSocketBindingServiceBinding.ServerRunnable runnable;
-
-    public TestSocketBindingServiceBinding(String name, int port, CompositeComponent parent) throws CoreRuntimeException {
-        super(name, parent);
-        this.port = port;
-    }
-
-    public QName getBindingType() {
-        return BINDING_TEST;
-    }
-    
-    public void start() {
-        executor = Executors.newSingleThreadExecutor();
-        // create a listener, note that a work scheduler should normally be used to spawn work in different threads
-        runnable = new ServerRunnable();
-        executor.execute(runnable);
-    }
-
-    public void stop() {
-        try {
-            runnable.setEnd(true);
-            socket.close();
-            executor.shutdownNow();
-        } catch (IOException e) {
-            throw new TestBindingRuntimeException(e);
-        }
-    }
-
-    /**
-     * Creates a socket listener in another thread which handles one client at a time. For a real binding, a work
-     * scheduler should be used
-     */
-    private class ServerRunnable implements Runnable {
-
-        private boolean end;
-
-        public void setEnd(boolean end) {
-            this.end = end;
-        }
-
-        public void run() {
-            Socket clientSocket;
-            ObjectInputStream is = null;
-            ObjectOutputStream os = null;
-            try {
-                socket = new ServerSocket(port);
-            } catch (IOException e) {
-                throw new TestBindingRuntimeException(e);
-            }
-            while (!end) {
-                try {
-                    clientSocket = socket.accept();
-                    is = new ObjectInputStream(clientSocket.getInputStream());
-                    String operation = is.readUTF();
-                    int argn = is.readInt();
-                    Object[] args = new Object[argn];
-                    for (int i = 0; i < argn; i++) {
-                        args[i] = is.readObject();
-                    }
-                    Map<Operation<?>, InboundInvocationChain> chains = getInboundWire().getInvocationChains();
-                    for (InboundInvocationChain chain : chains.values()) {
-                        if (chain.getOperation().getName().equals(operation)) {
-                            Message message = new MessageImpl();
-                            message.setTargetInvoker(chain.getTargetInvoker());
-                            message.setBody(args);
-                            message = chain.getHeadInterceptor().invoke(message);
-                            os = new ObjectOutputStream(clientSocket.getOutputStream());
-                            os.writeObject(message.getBody());
-                            os.flush();
-                        }
-                    }
-                } catch (IOException e) {
-                    throw new TestBindingRuntimeException(e);
-                } catch (ClassNotFoundException e) {
-                    throw new TestBindingRuntimeException(e);
-                } finally {
-                    if (os != null) {
-                        try {
-                            os.close();
-                        } catch (IOException e) {
-                            // ingore
-                        }
-                    }
-                    if (is != null) {
-                        try {
-                            is.close();
-                        } catch (IOException e) {
-                            // ignore
-                        }
-                    }
-                }
-            }
-        }
-    }
-}