1 files changed, 114 insertions, 0 deletions
diff --git a/sca-java-1.x/branches/sca-java-integration/sca/kernel/core/src/main/java/org/apache/tuscany/core/wire/jdk/JDKWireService.java b/sca-java-1.x/branches/sca-java-integration/sca/kernel/core/src/main/java/org/apache/tuscany/core/wire/jdk/JDKWireService.java
new file mode 100644
index 0000000000..e15b851351
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-integration/sca/kernel/core/src/main/java/org/apache/tuscany/core/wire/jdk/JDKWireService.java
@@ -0,0 +1,114 @@
+/*
+ * 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.wire.jdk;
+
+import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
+import java.util.Map;
+
+import org.osoa.sca.annotations.Constructor;
+import org.osoa.sca.annotations.EagerInit;
+
+import org.apache.tuscany.spi.annotation.Autowire;
+import org.apache.tuscany.spi.component.WorkContext;
+import org.apache.tuscany.spi.policy.PolicyBuilderRegistry;
+import org.apache.tuscany.spi.wire.InboundWire;
+import org.apache.tuscany.spi.wire.OutboundChainHolder;
+import org.apache.tuscany.spi.wire.OutboundWire;
+import org.apache.tuscany.spi.wire.ProxyCreationException;
+import org.apache.tuscany.spi.wire.Wire;
+import org.apache.tuscany.spi.wire.WireInvocationHandler;
+
+import org.apache.tuscany.core.wire.WireServiceExtension;
+
+/**
+ * the default implementation of a wire service that uses JDK dynamic proxies
+ *
+ * @version $$Rev$$ $$Date$$
+ */
+@EagerInit
+public class JDKWireService extends WireServiceExtension {
+
+    public JDKWireService() {
+        super(null, null);
+    }
+
+    @Constructor
+    public JDKWireService(@Autowire WorkContext context, @Autowire PolicyBuilderRegistry policyRegistry) {
+        super(context, policyRegistry);
+    }
+
+    public <T> T createProxy(Class<T> interfaze, Wire wire) throws ProxyCreationException {
+        assert interfaze != null;
+        assert wire != null;
+        if (wire instanceof InboundWire) {
+            InboundWire inbound = (InboundWire) wire;
+            JDKInboundInvocationHandler handler = new JDKInboundInvocationHandler(interfaze, inbound, context);
+            ClassLoader cl = interfaze.getClassLoader();
+            return interfaze.cast(Proxy.newProxyInstance(cl, new Class[]{interfaze}, handler));
+        } else if (wire instanceof OutboundWire) {
+            OutboundWire outbound = (OutboundWire) wire;
+            JDKOutboundInvocationHandler handler = new JDKOutboundInvocationHandler(interfaze, outbound, context);
+            ClassLoader cl = interfaze.getClassLoader();
+            return interfaze.cast(Proxy.newProxyInstance(cl, new Class[]{interfaze}, handler));
+        } else {
+            throw new ProxyCreationException("Invalid wire type", wire.getClass().getName());
+        }
+    }
+
+    public <T> T createProxy(Class<T> interfaze, Wire wire, Map<Method, OutboundChainHolder> mapping)
+        throws ProxyCreationException {
+        assert interfaze != null;
+        assert wire != null;
+        assert mapping != null;
+        if (wire instanceof InboundWire) {
+            InboundWire inbound = (InboundWire) wire;
+            JDKInboundInvocationHandler handler = new JDKInboundInvocationHandler(interfaze, inbound, context);
+            ClassLoader cl = interfaze.getClassLoader();
+            return interfaze.cast(Proxy.newProxyInstance(cl, new Class[]{interfaze}, handler));
+        } else if (wire instanceof OutboundWire) {
+            OutboundWire outbound = (OutboundWire) wire;
+            JDKOutboundInvocationHandler handler = new JDKOutboundInvocationHandler(interfaze, outbound, context);
+            ClassLoader cl = interfaze.getClassLoader();
+            return interfaze.cast(Proxy.newProxyInstance(cl, new Class[]{interfaze}, handler));
+        } else {
+            throw new ProxyCreationException("Invalid wire type", wire.getClass().getName());
+        }
+    }
+
+    public Object createCallbackProxy(Class<?> interfaze, InboundWire wire) throws ProxyCreationException {
+        ClassLoader cl = interfaze.getClassLoader();
+        JDKCallbackInvocationHandler handler = new JDKCallbackInvocationHandler(wire, context);
+        return interfaze.cast(Proxy.newProxyInstance(cl, new Class[]{interfaze}, handler));
+    }
+
+    public WireInvocationHandler createHandler(Class<?> interfaze, Wire wire) {
+        assert wire != null;
+        if (wire instanceof InboundWire) {
+            InboundWire inbound = (InboundWire) wire;
+            return new JDKInboundInvocationHandler(interfaze, inbound, context);
+        } else if (wire instanceof OutboundWire) {
+            OutboundWire outbound = (OutboundWire) wire;
+            return new JDKOutboundInvocationHandler(interfaze, outbound, context);
+        } else {
+            throw new ProxyCreationException("Invalid wire type", wire.getClass().getName());
+        }
+    }
+
+}