From 64dee3e1fd77da265adf4feb83c9928e88c20bb2 Mon Sep 17 00:00:00 2001 From: rfeng Date: Thu, 4 Mar 2010 04:57:14 +0000 Subject: Delete obsolete modules git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@918852 13f79535-47bb-0310-9956-ffa450edef68 --- .../sca/client/rmi/SCAClientProxyHandler.java | 105 --------------------- 1 file changed, 105 deletions(-) delete mode 100644 sca-java-2.x/trunk/modules/sca-client-rmi/src/main/java/org/apache/tuscany/sca/client/rmi/SCAClientProxyHandler.java (limited to 'sca-java-2.x/trunk/modules/sca-client-rmi/src/main/java/org/apache/tuscany/sca/client/rmi/SCAClientProxyHandler.java') diff --git a/sca-java-2.x/trunk/modules/sca-client-rmi/src/main/java/org/apache/tuscany/sca/client/rmi/SCAClientProxyHandler.java b/sca-java-2.x/trunk/modules/sca-client-rmi/src/main/java/org/apache/tuscany/sca/client/rmi/SCAClientProxyHandler.java deleted file mode 100644 index c8c60edd53..0000000000 --- a/sca-java-2.x/trunk/modules/sca-client-rmi/src/main/java/org/apache/tuscany/sca/client/rmi/SCAClientProxyHandler.java +++ /dev/null @@ -1,105 +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.sca.client.rmi; - -import java.lang.reflect.InvocationHandler; -import java.lang.reflect.Method; -import java.net.URI; -import java.util.List; - -import org.apache.tuscany.sca.assembly.AssemblyFactory; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.binding.rmi.provider.RMIBindingInvoker; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.core.FactoryExtensionPoint; -import org.apache.tuscany.sca.host.rmi.ExtensibleRMIHost; -import org.apache.tuscany.sca.host.rmi.RMIHost; -import org.apache.tuscany.sca.host.rmi.RMIHostExtensionPoint; -import org.apache.tuscany.sca.node.Node; -import org.apache.tuscany.sca.node.NodeFactory; -import org.apache.tuscany.sca.node.impl.NodeFactoryImpl; -import org.apache.tuscany.sca.runtime.DomainRegistryFactory; -import org.apache.tuscany.sca.runtime.DomainRegistryFactoryExtensionPoint; -import org.apache.tuscany.sca.runtime.EndpointRegistry; -import org.oasisopen.sca.NoSuchServiceException; - -public class SCAClientProxyHandler implements InvocationHandler { - - protected NodeFactoryImpl nodeFactory; - protected ExtensionPointRegistry extensionsRegistry; - protected EndpointRegistry endpointRegistry; - protected EndpointReference endpointReference; - protected String registryURI; - protected String domainURI; - protected String serviceName; - protected RMIHost rmiHost; - - public SCAClientProxyHandler(NodeFactoryImpl nodeFactory, String registryURI, String domainURI, String serviceName) { - this.nodeFactory = nodeFactory; - this.registryURI = registryURI; - this.domainURI = domainURI; - this.serviceName = serviceName; - } - - public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { - Node node = null; - try { - - nodeFactory = (NodeFactoryImpl)NodeFactory.newInstance(); - node = nodeFactory.createNode(URI.create(registryURI)).start(); - this.extensionsRegistry = nodeFactory.getExtensionPoints(); - RMIHostExtensionPoint rmiHosts = extensionsRegistry.getExtensionPoint(RMIHostExtensionPoint.class); - this.rmiHost = new ExtensibleRMIHost(rmiHosts); - - FactoryExtensionPoint factories = extensionsRegistry.getExtensionPoint(FactoryExtensionPoint.class); - AssemblyFactory assemblyFactory = factories.getFactory(AssemblyFactory.class); - - this.endpointReference = assemblyFactory.createEndpointReference(); - endpointReference.setReference(assemblyFactory.createComponentReference()); - Endpoint targetEndpoint = assemblyFactory.createEndpoint(); - targetEndpoint.setURI(serviceName); - endpointReference.setTargetEndpoint(targetEndpoint); - DomainRegistryFactoryExtensionPoint factoriesx = extensionsRegistry.getExtensionPoint(DomainRegistryFactoryExtensionPoint.class); - for (DomainRegistryFactory factory : factoriesx.getDomainRegistryFactories()) { - for (EndpointRegistry endpointRegistry : factory.getEndpointRegistries()) { - if (endpointRegistry.getDomainURI().equals(domainURI)) { - this.endpointRegistry = endpointRegistry; - } - } - } - - List endpoints = endpointRegistry.findEndpoint(endpointReference); - if (endpoints.size() <1 ) { - throw new NoSuchServiceException(serviceName); - } - - String uri = endpoints.get(0).getBinding().getURI(); - RMIBindingInvoker invoker = new RMIBindingInvoker(rmiHost, uri, method); - - return invoker.invokeTarget(args); - - } finally { - if (node != null) { - node.stop(); - } - } - } -} -- cgit v1.2.3