diff options
Diffstat (limited to 'sca-java-2.x/tags/2.0-Beta2-RC3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl2.java')
-rw-r--r-- | sca-java-2.x/tags/2.0-Beta2-RC3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl2.java | 94 |
1 files changed, 0 insertions, 94 deletions
diff --git a/sca-java-2.x/tags/2.0-Beta2-RC3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl2.java b/sca-java-2.x/tags/2.0-Beta2-RC3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl2.java deleted file mode 100644 index 3734fcfde2..0000000000 --- a/sca-java-2.x/tags/2.0-Beta2-RC3/modules/sca-client-impl/src/main/java/org/apache/tuscany/sca/client/impl/SCAClientFactoryImpl2.java +++ /dev/null @@ -1,94 +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.impl; - -import java.lang.reflect.InvocationHandler; -import java.lang.reflect.Proxy; -import java.net.URI; -import java.util.List; - -import org.apache.tuscany.sca.assembly.Endpoint; -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.node.impl.NodeImpl; -import org.oasisopen.sca.NoSuchDomainException; -import org.oasisopen.sca.NoSuchServiceException; -import org.oasisopen.sca.client.SCAClientFactory; -import org.oasisopen.sca.client.SCAClientFactoryFinder; - -public class SCAClientFactoryImpl2 extends SCAClientFactory { - - public static void setSCAClientFactoryFinder(SCAClientFactoryFinder factoryFinder) { - SCAClientFactory.factoryFinder = factoryFinder; - } - - public SCAClientFactoryImpl2(URI domainURI) throws NoSuchDomainException { - super(domainURI); - checkDomainURI(domainURI); - } - - private void checkDomainURI(URI domainURI) throws NoSuchDomainException { - // Check for local node - String domainName = getDomainName(); - for ( NodeFactory nodeFactory : NodeFactory.getNodeFactories()) { - List<Node> nodes = ((NodeFactoryImpl)nodeFactory).getNodesInDomain(domainName); - if ( !nodes.isEmpty() ) { - return; - } - } - - // Check for remote node - SCAClientHandler handler = new SCAClientHandler(domainName, null, null); - handler.checkDomain(); - } - - @SuppressWarnings("unchecked") - @Override - public <T> T getService(Class<T> serviceInterface, String serviceName) throws NoSuchServiceException, NoSuchDomainException { - - boolean foundDomain = false; - for (NodeFactory nodeFactory : NodeFactory.getNodeFactories()) { - for (Node node : ((NodeFactoryImpl)nodeFactory).getNodesInDomain(getDomainName())) { - foundDomain = true; - for (Endpoint ep : ((NodeImpl)node).getServiceEndpoints()) { - if (ep.matches(serviceName)) { - return node.getService(serviceInterface, serviceName); - } - } - } - } - - // assume that if a local node with the looked for domain name is found then that will - // know about all services in the domain so if the service isn't found then it doesn't exist - if (foundDomain) { - throw new NoSuchServiceException(serviceName); - } - - InvocationHandler handler = new SCAClientHandler(getDomainURI().toString(), serviceName, serviceInterface); - return (T)Proxy.newProxyInstance(serviceInterface.getClassLoader(), new Class[]{serviceInterface}, handler); - } - - private String getDomainName() { - // TODO: if the domain URI encodes config (eg uri:someDomain?bla=etc) then need to parse the domain name - String domainName = getDomainURI().toString(); - return domainName; - } -} |