1 files changed, 0 insertions, 171 deletions
diff --git a/branches/pre-spec-changes/kernel/core/src/test/java/org/apache/tuscany/core/builder/NonBlockingForwardSyncCallbackConnectionTestCase.java b/branches/pre-spec-changes/kernel/core/src/test/java/org/apache/tuscany/core/builder/NonBlockingForwardSyncCallbackConnectionTestCase.java
deleted file mode 100644
index 0e425b73bf..0000000000
--- a/branches/pre-spec-changes/kernel/core/src/test/java/org/apache/tuscany/core/builder/NonBlockingForwardSyncCallbackConnectionTestCase.java
+++ /dev/null
@@ -1,171 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *   http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.tuscany.core.builder;
-
-import java.lang.reflect.Type;
-import java.util.Map;
-import java.util.HashMap;
-
-import org.apache.tuscany.spi.model.Operation;
-import org.apache.tuscany.spi.model.ServiceContract;
-import org.apache.tuscany.spi.component.AtomicComponent;
-import org.apache.tuscany.spi.component.WorkContext;
-import org.apache.tuscany.spi.wire.InboundWire;
-import org.apache.tuscany.spi.wire.TargetInvoker;
-import org.apache.tuscany.spi.wire.InboundInvocationChain;
-import org.apache.tuscany.spi.wire.OutboundWire;
-import org.apache.tuscany.spi.wire.OutboundInvocationChain;
-import org.apache.tuscany.spi.wire.Message;
-import org.apache.tuscany.spi.wire.MessageImpl;
-import org.apache.tuscany.spi.wire.WireService;
-import org.apache.tuscany.spi.wire.Interceptor;
-import org.apache.tuscany.spi.QualifiedName;
-import org.apache.tuscany.spi.idl.java.JavaServiceContract;
-import org.apache.tuscany.spi.services.work.WorkScheduler;
-import org.apache.tuscany.spi.services.work.NotificationListener;
-
-import junit.framework.TestCase;
-import org.easymock.EasyMock;
-import org.apache.tuscany.core.wire.InboundWireImpl;
-import org.apache.tuscany.core.wire.InboundInvocationChainImpl;
-import org.apache.tuscany.core.wire.OutboundWireImpl;
-import org.apache.tuscany.core.wire.OutboundInvocationChainImpl;
-import org.apache.tuscany.core.wire.jdk.JDKWireService;
-import org.apache.tuscany.core.component.WorkContextImpl;
-
-/**
- * Verifies connections with non-blocking forward and synchronous callback invocations
- *
- * @version $Rev$ $Date$
- */
-public class NonBlockingForwardSyncCallbackConnectionTestCase extends TestCase {
-    private Operation<Type> operation;
-    private Operation<Type> callbackOperation;
-    private ServiceContract<Type> contract;
-    private ConnectorImpl connector;
-
-    public void testNonBlockingForwardAndSyncCallbackAtomicToAtomic() throws Exception {
-        AtomicComponent target = EasyMock.createMock(AtomicComponent.class);
-        EasyMock.expect(target.isSystem()).andReturn(false).anyTimes();
-        EasyMock.expect(target.getName()).andReturn("target").anyTimes();
-        EasyMock.expect(target.createTargetInvoker(EasyMock.eq("service"),
-            EasyMock.isA(Operation.class),
-            EasyMock.isA(InboundWire.class))).andReturn(EasyMock.createNiceMock(TargetInvoker.class));
-        EasyMock.replay(target);
-
-        InboundWire inboundWire = new InboundWireImpl();
-        inboundWire.setContainer(target);
-        inboundWire.setServiceContract(contract);
-        InboundInvocationChain inboundChain = new InboundInvocationChainImpl(operation);
-        inboundChain.addInterceptor(new NonBlockingForwardSyncCallbackConnectionTestCase.MockInterceptor());
-        inboundWire.addInvocationChain(operation, inboundChain);
-
-        AtomicComponent source = createSource();
-        OutboundWire outboundWire = new OutboundWireImpl();
-        outboundWire.setContainer(source);
-        outboundWire.setServiceContract(contract);
-        outboundWire.setTargetName(new QualifiedName("target/service"));
-        OutboundInvocationChain outboundChain = new OutboundInvocationChainImpl(operation);
-        outboundWire.addInvocationChain(operation, outboundChain);
-
-        InboundInvocationChain callbackInboundChain = new InboundInvocationChainImpl(callbackOperation);
-        callbackInboundChain.addInterceptor(new NonBlockingForwardSyncCallbackConnectionTestCase.MockInterceptor());
-        Map<Operation<?>, InboundInvocationChain> chains = new HashMap<Operation<?>, InboundInvocationChain>();
-        chains.put(callbackOperation, callbackInboundChain);
-        outboundWire.addTargetCallbackInvocationChains(chains);
-
-        connector.connect(outboundWire, inboundWire, true);
-
-        // test the forward request
-        Message msg = new MessageImpl();
-        msg.setBody("foo");
-        Message ret = outboundChain.getHeadInterceptor().invoke(msg);
-        assertEquals(null, ret.getBody());
-
-        // test the callback
-        msg = new MessageImpl();
-        msg.setBody("callback");
-        Map<Operation<?>, OutboundInvocationChain> callbackChains =
-            inboundWire.getSourceCallbackInvocationChains("source");
-        OutboundInvocationChain callbackInvocationChain = callbackChains.get(callbackOperation);
-        ret = callbackInvocationChain.getHeadInterceptor().invoke(msg);
-        assertEquals("callback", ret.getBody());
-
-        EasyMock.verify(source);
-        EasyMock.verify(target);
-    }
-
-
-    protected void setUp() throws Exception {
-        super.setUp();
-        WorkContext context = new WorkContextImpl();
-        WireService wireService = new JDKWireService(null, null);
-        WorkScheduler scheduler = new NonBlockingForwardSyncCallbackConnectionTestCase.MockWorkScheduler();
-        connector = new ConnectorImpl(wireService, null, scheduler, context);
-        operation = new Operation<Type>("bar", null, null, null);
-        operation.setNonBlocking(true);
-        callbackOperation = new Operation<Type>("callback", null, null, null);
-        contract = new JavaServiceContract();
-        Map<String, Operation<Type>> ops = new HashMap<String, Operation<Type>>();
-        ops.put("callback", callbackOperation);
-        contract.setCallbackOperations(ops);
-    }
-
-    private AtomicComponent createSource() throws Exception {
-        AtomicComponent component = EasyMock.createMock(AtomicComponent.class);
-        EasyMock.expect(component.getName()).andReturn("source").atLeastOnce();
-        EasyMock.expect(component.isSystem()).andReturn(false).anyTimes();
-        EasyMock.expect(component.createTargetInvoker(EasyMock.eq("callback"),
-            EasyMock.isA(Operation.class),
-            (InboundWire) EasyMock.isNull())).andReturn(EasyMock.createNiceMock(TargetInvoker.class));
-        EasyMock.replay(component);
-        return component;
-    }
-
-    private class MockInterceptor implements Interceptor {
-
-        public Message invoke(Message msg) {
-            return msg;
-        }
-
-        public void setNext(Interceptor next) {
-
-        }
-
-        public Interceptor getNext() {
-            return null;
-        }
-
-        public boolean isOptimizable() {
-            return false;
-        }
-    }
-
-    private class MockWorkScheduler implements WorkScheduler {
-
-        public <T extends Runnable> void scheduleWork(T work, NotificationListener<T> listener) {
-            throw new UnsupportedOperationException();
-        }
-
-        public <T extends Runnable> void scheduleWork(T work) {
-            work.run();
-        }
-    }
-
-}