summaryrefslogtreecommitdiffstats
path: root/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl
diff options
context:
space:
mode:
authorfmoga <fmoga@13f79535-47bb-0310-9956-ffa450edef68>2010-09-20 13:53:05 +0000
committerfmoga <fmoga@13f79535-47bb-0310-9956-ffa450edef68>2010-09-20 13:53:05 +0000
commit856b308803a5d2d7661081044595e3b3845f904a (patch)
tree183fcf89903f7baea33e1530f85e450d83a1e4d0 /sandbox/samples/temp/implementation-extension/src/main/java/sample/impl
parent4d2b69ca607058e0d4d8ea1005272af24e2445f2 (diff)
Moved more samples.
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@998929 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sandbox/samples/temp/implementation-extension/src/main/java/sample/impl')
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/EmbedUtil.java311
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/ImplUtil.java148
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementation.java41
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementationProcessor.java174
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleJavaInvoker.java52
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProvider.java91
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProviderFactory.java48
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLInvoker.java56
-rw-r--r--sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLProxy.java57
9 files changed, 0 insertions, 978 deletions
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/EmbedUtil.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/EmbedUtil.java
deleted file mode 100644
index 0ccbcc9e36..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/EmbedUtil.java
+++ /dev/null
@@ -1,311 +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 sample.impl;
-
-import java.net.URI;
-import java.net.URL;
-import java.util.Arrays;
-
-import javax.wsdl.PortType;
-import javax.xml.namespace.QName;
-
-import org.apache.tuscany.sca.assembly.AssemblyFactory;
-import org.apache.tuscany.sca.assembly.Component;
-import org.apache.tuscany.sca.assembly.ComponentReference;
-import org.apache.tuscany.sca.assembly.ComponentService;
-import org.apache.tuscany.sca.assembly.Composite;
-import org.apache.tuscany.sca.assembly.Contract;
-import org.apache.tuscany.sca.assembly.Implementation;
-import org.apache.tuscany.sca.assembly.Reference;
-import org.apache.tuscany.sca.assembly.Service;
-import org.apache.tuscany.sca.contribution.Artifact;
-import org.apache.tuscany.sca.contribution.Contribution;
-import org.apache.tuscany.sca.contribution.ContributionFactory;
-import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
-import org.apache.tuscany.sca.contribution.processor.ExtensibleURLArtifactProcessor;
-import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
-import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessorExtensionPoint;
-import org.apache.tuscany.sca.contribution.resolver.ExtensibleModelResolver;
-import org.apache.tuscany.sca.contribution.resolver.ModelResolverExtensionPoint;
-import org.apache.tuscany.sca.core.ExtensionPointRegistry;
-import org.apache.tuscany.sca.core.FactoryExtensionPoint;
-import org.apache.tuscany.sca.databinding.xml.DOMDataBinding;
-import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException;
-import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLDefinition;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLFactory;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLInterface;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLObject;
-import org.apache.tuscany.sca.node.Node;
-import org.apache.tuscany.sca.node.NodeFactory;
-import org.apache.tuscany.sca.provider.ProviderFactoryExtensionPoint;
-
-/**
- * A few utility functions to help embed a Tuscany runtime, and a simple DSL
- * to help assemble and run SCDL.
- */
-public class EmbedUtil {
-
- /**
- * A runtime embedder context, which conveniently initializes a Node factory
- * and gets the various registries, factories and extension points we need.
- */
- static class Context {
- final NodeFactory nf;
- final ExtensionPointRegistry epr;
- final FactoryExtensionPoint fep;
- final ContributionFactory cf;
- final AssemblyFactory af;
- final JavaInterfaceFactory jif;
- final WSDLFactory wif;
- final URLArtifactProcessorExtensionPoint apep;
- final ExtensibleURLArtifactProcessor aproc;
- final ModelResolverExtensionPoint mrep;
- final ProviderFactoryExtensionPoint pfep;
-
- Context(final NodeFactory nf) {
- this.nf = nf;
- epr = nf.getExtensionPointRegistry();
- fep = epr.getExtensionPoint(FactoryExtensionPoint.class);
- cf = fep.getFactory(ContributionFactory.class);
- af = fep.getFactory(AssemblyFactory.class);
- jif = fep.getFactory(JavaInterfaceFactory.class);
- wif = fep.getFactory(WSDLFactory.class);
- apep = epr.getExtensionPoint(URLArtifactProcessorExtensionPoint.class);
- aproc = new ExtensibleURLArtifactProcessor(apep);
- mrep = epr.getExtensionPoint(ModelResolverExtensionPoint.class);
- pfep = epr.getExtensionPoint(ProviderFactoryExtensionPoint.class);
- }
- }
-
- static Context embedContext(NodeFactory nf) {
- return new Context(nf);
- }
-
- /**
- * A mini DSL to help build and assemble contributions and SCDL composites.
- */
- interface Builder<T> {
- T build(Context ec);
- }
-
- static <T> T build(final Builder<T> builder, final Context ec) {
- return builder.build(ec);
- }
-
- /**
- * Return a contribution builder.
- */
- static Builder<Contribution> contrib(final String uri, final String loc, final Builder<Artifact>... artifacts) {
- return new Builder<Contribution>() {
- public Contribution build(final Context ec) {
- final Contribution c = ec.cf.createContribution();
- c.setURI(uri);
- c.setLocation(loc);
- c.setModelResolver(new ExtensibleModelResolver(c, ec.mrep, ec.fep));
- for(Builder<Artifact> a: artifacts)
- c.getArtifacts().add(a.build(ec));
- return c;
- }
- };
- }
-
- /**
- * Return an artifact builder.
- */
- static Builder<Artifact> artifact(final String uri, final Object model) {
- return new Builder<Artifact>() {
- public Artifact build(final Context ec) {
- final Artifact a = ec.cf.createArtifact();
- a.setURI(uri);
- a.setModel(model);
- return a;
- }
- };
- }
-
- /**
- * Return a composite builder.
- */
- static Builder<Composite> composite(final String ns, final String name, final Builder<Component>... components) {
- return new Builder<Composite>() {
- public Composite build(final Context ec) {
- final Composite compos = ec.af.createComposite();
- compos.setName(new QName(ns, name));
- for(final Builder<Component> c: components)
- compos.getComponents().add(c.build(ec));
- return compos;
- }
- };
- }
-
- /**
- * Return a component builder.
- */
- static Builder<Component> component(final String name, final Builder<Implementation> impl, final Builder<ComponentReference>... references) {
- return new Builder<Component>() {
- public Component build(final Context ec) {
- final Component c = ec.af.createComponent();
- c.setName(name);
- c.setImplementation(impl.build(ec));
- for(Builder<ComponentReference> r: references)
- c.getReferences().add(r.build(ec));
- return c;
- }
- };
- }
-
- /**
- * Return an implementation builder.
- */
- static Builder<Implementation> implementation(final Class<?> clazz, final Builder<Contract>... contracts) {
- return new Builder<Implementation>() {
- public SampleImplementation build(final Context ec) {
- final SampleImplementation impl = ImplUtil.implementation(clazz.getName());
- impl.clazz = clazz;
- impl.setUnresolved(false);
- for(final Builder<Contract> b: contracts) {
- Contract c = b.build(ec);
- if(c instanceof Service)
- impl.getServices().add((Service)c);
- else
- impl.getReferences().add((Reference)c);
- }
- return impl;
- }
- };
- }
-
- /**
- * Return a reference builder.
- */
- static Builder<Contract> reference(final String name, final Class<?> c) {
- return new Builder<Contract>() {
- public Reference build(final Context ec) {
- try {
- return ImplUtil.reference(name, c, ec.jif, ec.af);
- } catch(InvalidInterfaceException e) {
- throw new RuntimeException(e);
- }
- }
- };
- }
-
- static Builder<Contract> reference(final String name, final WSDLInterface c) {
- return new Builder<Contract>() {
- public Reference build(final Context ec) {
- return ImplUtil.reference(name, c, ec.wif, ec.af);
- }
- };
- }
-
- static Builder<ComponentReference> reference(final String name, final String target) {
- return new Builder<ComponentReference>() {
- public ComponentReference build(final Context ec) {
- final ComponentReference r = ec.af.createComponentReference();
- r.setName(name);
- final ComponentService s = ec.af.createComponentService();
- s.setUnresolved(true);
- s.setName(target);
- r.getTargets().add(s);
- return r;
- }
- };
- }
-
- /**
- * Return a service builder.
- */
- static Builder<Contract> service(final Class<?> c) {
- return new Builder<Contract>() {
- public Service build(final Context ec) {
- try {
- return ImplUtil.service(c, ec.jif, ec.af);
- } catch(InvalidInterfaceException e) {
- throw new RuntimeException(e);
- }
- }
- };
- }
-
- static Builder<Contract> service(final WSDLInterface c) {
- return new Builder<Contract>() {
- public Service build(final Context ec) {
- return ImplUtil.service(c, ec.wif, ec.af);
- }
- };
- }
-
- /**
- * Return a WSDLInterface builder which loads a WSDL into a contribution.
- */
- static Builder<WSDLInterface> wsdli(final String uri, final String ns, final String name, final Contribution c) {
- return new Builder<WSDLInterface>() {
- public WSDLInterface build(final Context ec) {
- try {
- final ProcessorContext ctx = new ProcessorContext();
- final WSDLDefinition wd = ec.aproc.read(null, new URI(uri), new URL(new URL(c.getLocation()), uri), ctx, WSDLDefinition.class);
- c.getModelResolver().addModel(wd, ctx);
- c.getModelResolver().resolveModel(WSDLDefinition.class, wd, ctx);
- final WSDLObject<PortType> pt = wd.getWSDLObject(PortType.class, new QName(ns, name));
- if(pt == null)
- throw new ContributionResolveException("Couldn't find " + name);
- final WSDLInterface nwi = ec.wif.createWSDLInterface(pt.getElement(), wd, c.getModelResolver(), null);
- nwi.setWsdlDefinition(wd);
- nwi.resetDataBinding(DOMDataBinding.NAME);
- return nwi;
- } catch(Exception e) {
- throw new RuntimeException(e);
- }
- }
- };
- }
-
- /**
- * Return the extension point registry used by our nodes.
- */
- static ExtensionPointRegistry extensionPoints(final Context ec) {
- return ec.epr;
- }
-
- /**
- * Return the provider factory extension point used by our nodes.
- */
- static ProviderFactoryExtensionPoint providerFactories(final Context ec) {
- return ec.pfep;
- }
-
- /**
- * Add a deployable composite to a contribution.
- */
- static Contribution deploy(final Contribution contrib, final Composite... comps) {
- for(Composite c: comps)
- contrib.getDeployables().add(c);
- return contrib;
- }
-
- /**
- * Configure a node with a list of contributions.
- */
- static Node node(final NodeFactory nf, final Contribution... contributions) {
- return nf.createNode(Arrays.asList(contributions));
- }
-
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/ImplUtil.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/ImplUtil.java
deleted file mode 100644
index abd4cd7ab0..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/ImplUtil.java
+++ /dev/null
@@ -1,148 +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 sample.impl;
-
-import java.lang.annotation.Annotation;
-
-import javax.xml.namespace.QName;
-
-import org.apache.tuscany.sca.assembly.AssemblyFactory;
-import org.apache.tuscany.sca.assembly.Reference;
-import org.apache.tuscany.sca.assembly.Service;
-import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException;
-import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceContract;
-import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLDefinition;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLFactory;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLInterface;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLInterfaceContract;
-
-import sample.api.Java;
-import sample.api.WSDL;
-
-/**
- * Utility functions to help develop a component implementation extension.
- */
-class ImplUtil {
-
- /**
- * Return a Sample implementation with the given name.
- */
- static SampleImplementation implementation(String name) {
- final SampleImplementation impl = new SampleImplementation(name);
- impl.setUnresolved(true);
- return impl;
- }
-
- /**
- * Return the Java class configured on an annotation.
- */
- static Class<?> clazz(final Annotation a) {
- return ((Java)a).value();
- }
-
- /**
- * Return the WSDL QName configured on an annotation.
- */
- static QName qname(final Annotation a) {
- final String uri = ((WSDL)a).value();
- final int h = uri.indexOf('#');
- return new QName(uri.substring(0, h), uri.substring(h + 1));
- }
-
- /**
- * Convert a Java class to an interface contract.
- */
- static JavaInterfaceContract contract(final Class<?> c, final JavaInterfaceFactory jif) throws InvalidInterfaceException {
- final JavaInterfaceContract ic = jif.createJavaInterfaceContract();
- ic.setInterface(jif.createJavaInterface(c));
- return ic;
- }
-
- /**
- * Convert a WSDL interface to an interface contract.
- */
- static WSDLInterfaceContract contract(final WSDLInterface wi, final WSDLFactory wf) {
- final WSDLInterfaceContract ic = wf.createWSDLInterfaceContract();
- ic.setInterface(wi);
- return ic;
- }
-
- /**
- * Convert a Java class to a service.
- */
- static Service service(final Class<?> c, final JavaInterfaceFactory jif, final AssemblyFactory af) throws InvalidInterfaceException {
- Service s = af.createService();
- s.setName(c.getSimpleName());
- s.setInterfaceContract(contract(c, jif));
- return s;
- }
-
- /**
- * Convert a WSDL interface to a service.
- */
- static Service service(final WSDLInterface wi, final WSDLFactory wf, final AssemblyFactory af) {
- Service s = af.createService();
- s.setName(wi.getName().getLocalPart());
- s.setInterfaceContract(contract(wi, wf));
- return s;
- }
-
- /**
- * Convert a name and Java class to a reference.
- */
- static Reference reference(final String name, final Class<?> c, final JavaInterfaceFactory jif, final AssemblyFactory af) throws InvalidInterfaceException {
- final Reference r = af.createReference();
- r.setName(name);
- r.setInterfaceContract(contract(c, jif));
- return r;
- }
-
- /**
- * Convert a name and WSDL interface to a reference.
- */
- static Reference reference(final String name, final WSDLInterface wi, final WSDLFactory wf, final AssemblyFactory af) {
- final Reference r = af.createReference();
- r.setName(name);
- r.setInterfaceContract(contract(wi, wf));
- return r;
- }
-
- /**
- * Convert a WSDL qname to a WSDL interface.
- */
- static WSDLInterface interfaze(final QName name, final WSDLFactory wif) {
- final WSDLInterface wir = wif.createWSDLInterface();
- wir.setUnresolved(true);
- wir.setName(name);
- return wir;
- }
-
- /**
- * Convert a WSDL qname to a WSDL definition.
- */
- static WSDLDefinition definition(final QName name, final WSDLFactory wif) {
- final WSDLDefinition wdr = wif.createWSDLDefinition();
- wdr.setUnresolved(true);
- wdr.setNamespace(name.getNamespaceURI());
- wdr.setNameOfPortTypeToResolve(name);
- return wdr;
- }
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementation.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementation.java
deleted file mode 100644
index 41ce71a732..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementation.java
+++ /dev/null
@@ -1,41 +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 sample.impl;
-
-import javax.xml.namespace.QName;
-
-import org.apache.tuscany.sca.assembly.impl.ImplementationImpl;
-
-/**
- * Model representing a Sample implementation in an SCA assembly.
- *
- * @version $Rev$ $Date$
- */
-public class SampleImplementation extends ImplementationImpl {
- static final QName QN = new QName(SCA11_TUSCANY_NS, "implementation.sample");
-
- final String name;
- Class<?> clazz;
-
- SampleImplementation(final String name) {
- super(QN);
- this.name = name;
- }
-
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementationProcessor.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementationProcessor.java
deleted file mode 100644
index 6017030d35..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleImplementationProcessor.java
+++ /dev/null
@@ -1,174 +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 sample.impl;
-
-import static javax.xml.stream.XMLStreamConstants.END_ELEMENT;
-import static sample.impl.SampleImplementation.QN;
-import static sample.impl.ImplUtil.clazz;
-import static sample.impl.ImplUtil.definition;
-import static sample.impl.ImplUtil.implementation;
-import static sample.impl.ImplUtil.interfaze;
-import static sample.impl.ImplUtil.qname;
-import static sample.impl.ImplUtil.reference;
-import static sample.impl.ImplUtil.service;
-
-import java.lang.annotation.Annotation;
-import java.lang.reflect.Field;
-
-import javax.wsdl.PortType;
-import javax.xml.namespace.QName;
-import javax.xml.stream.XMLStreamException;
-import javax.xml.stream.XMLStreamReader;
-import javax.xml.stream.XMLStreamWriter;
-
-import org.apache.tuscany.sca.assembly.AssemblyFactory;
-import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
-import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
-import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
-import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
-import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
-import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
-import org.apache.tuscany.sca.contribution.resolver.ClassReference;
-import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
-import org.apache.tuscany.sca.core.ExtensionPointRegistry;
-import org.apache.tuscany.sca.core.FactoryExtensionPoint;
-import org.apache.tuscany.sca.databinding.xml.DOMDataBinding;
-import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException;
-import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLDefinition;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLFactory;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLInterface;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLObject;
-
-import sample.api.Java;
-import sample.api.WSDL;
-
-/**
- * StAX artifact processor for Sample implementations.
- *
- * @version $Rev$ $Date$
- */
-public class SampleImplementationProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<SampleImplementation> {
- final AssemblyFactory af;
- final JavaInterfaceFactory jif;
- final WSDLFactory wf;
-
- public SampleImplementationProcessor(final ExtensionPointRegistry ep) {
- final FactoryExtensionPoint fep = ep.getExtensionPoint(FactoryExtensionPoint.class);
- this.af = fep.getFactory(AssemblyFactory.class);
- this.jif = fep.getFactory(JavaInterfaceFactory.class);
- this.wf = fep.getFactory(WSDLFactory.class);
- }
-
- public QName getArtifactType() {
- return QN;
- }
-
- public Class<SampleImplementation> getModelType() {
- return SampleImplementation.class;
- }
-
- public SampleImplementation read(final XMLStreamReader r, final ProcessorContext ctx) throws ContributionReadException, XMLStreamException {
- // Read the component implementation element
- final SampleImplementation impl = implementation(r.getAttributeValue(null, "class"));
- while(r.hasNext() && !(r.next() == END_ELEMENT && QN.equals(r.getName())))
- ;
- return impl;
- }
-
- public void resolve(final SampleImplementation impl, final ModelResolver res, final ProcessorContext ctx) throws ContributionResolveException {
- try {
- // Resolve and introspect the implementation class
- impl.clazz = resolve(impl.name, res, ctx);
-
- for(final Annotation a: impl.clazz.getAnnotations()) {
- if(a instanceof Java)
- impl.getServices().add(service(clazz(a), jif, af));
- else if(a instanceof WSDL)
- impl.getServices().add(service(resolve(qname(a), res, ctx, wf), wf, af));
- }
-
- for(Field f: impl.clazz.getDeclaredFields()) {
- for(final Annotation a: f.getAnnotations()) {
- if(a instanceof Java)
- impl.getReferences().add(reference(f.getName(), clazz(a), jif, af));
- else if(a instanceof WSDL)
- impl.getReferences().add(reference(f.getName(), resolve(qname(a), res, ctx, wf), wf, af));
- }
- }
-
- impl.setUnresolved(false);
- } catch(InvalidInterfaceException e) {
- throw new ContributionResolveException(e);
- }
- }
-
- public void write(final SampleImplementation impl, final XMLStreamWriter w, final ProcessorContext ctx) throws ContributionWriteException, XMLStreamException {
- writeStart(w, QN.getNamespaceURI(), QN.getLocalPart(), new XAttr("class", impl.name));
- writeEnd(w);
- }
-
- /**
- * Resolve a Java class.
- */
- static Class<?> resolve(final String name, final ModelResolver res, final ProcessorContext ctx) throws ContributionResolveException {
- final ClassReference cr = res.resolveModel(ClassReference.class, new ClassReference(name), ctx);
- if(cr.getJavaClass() != null)
- return cr.getJavaClass();
- throw new ContributionResolveException(new ClassNotFoundException(name));
- }
-
- /**
- * Resolve a WSDL interface.
- */
- static WSDLInterface resolve(final QName name, final ModelResolver res, final ProcessorContext ctx, final WSDLFactory wif) throws ContributionResolveException {
- final WSDLInterface wi = res.resolveModel(WSDLInterface.class, interfaze(name, wif), ctx);
- if(!wi.isUnresolved())
- return domBound(wi);
-
- final WSDLDefinition wd = res.resolveModel(WSDLDefinition.class, definition(wi.getName(), wif), ctx);
- if(wd.isUnresolved())
- throw new ContributionResolveException("Couldn't find " + name.getNamespaceURI());
-
- WSDLObject<PortType> pt = wd.getWSDLObject(PortType.class, name);
- if(pt == null)
- throw new ContributionResolveException("Couldn't find " + name);
- try {
- final WSDLInterface nwi = wif.createWSDLInterface(pt.getElement(), wd, res, ctx.getMonitor());
- nwi.setWsdlDefinition(wd);
- res.addModel(nwi, ctx);
- return domBound(nwi);
- } catch(InvalidInterfaceException e) {
- throw new ContributionResolveException(e);
- }
- }
-
- /**
- * Return a WSDL interface configured to use a DOM databinding.
- */
- static WSDLInterface domBound(WSDLInterface wi) throws ContributionResolveException {
- try {
- final WSDLInterface domwi = (WSDLInterface)wi.clone();
- domwi.resetDataBinding(DOMDataBinding.NAME);
- return domwi;
- } catch(CloneNotSupportedException e) {
- throw new ContributionResolveException(e);
- }
- }
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleJavaInvoker.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleJavaInvoker.java
deleted file mode 100644
index 244251c4c9..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleJavaInvoker.java
+++ /dev/null
@@ -1,52 +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 sample.impl;
-
-import java.lang.reflect.Method;
-
-import org.apache.tuscany.sca.interfacedef.java.JavaOperation;
-import org.apache.tuscany.sca.invocation.Invoker;
-import org.apache.tuscany.sca.invocation.Message;
-
-/**
- * Invoker for Sample components that implement a Java interface.
- *
- * @version $Rev$ $Date$
- */
-class SampleJavaInvoker implements Invoker {
- final Object instance;
- final Method method;
-
- SampleJavaInvoker(final JavaOperation op, final Class<?> clazz, final Object instance) throws SecurityException, NoSuchMethodException {
- this.instance = instance;
- this.method = clazz.getMethod(op.getJavaMethod().getName(), op.getJavaMethod().getParameterTypes());
- }
-
- public Message invoke(final Message msg) {
- try {
- // Call the method that implements the operation
- msg.setBody(method.invoke(instance, (Object[])msg.getBody()));
- } catch(Exception e) {
- e.printStackTrace();
- msg.setFaultBody(e.getCause());
- }
- return msg;
- }
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProvider.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProvider.java
deleted file mode 100644
index 5d946b037b..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProvider.java
+++ /dev/null
@@ -1,91 +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 sample.impl;
-
-import java.lang.reflect.Field;
-
-import org.apache.tuscany.sca.assembly.ComponentReference;
-import org.apache.tuscany.sca.core.invocation.ProxyFactory;
-import org.apache.tuscany.sca.interfacedef.Interface;
-import org.apache.tuscany.sca.interfacedef.Operation;
-import org.apache.tuscany.sca.interfacedef.java.JavaInterface;
-import org.apache.tuscany.sca.interfacedef.java.JavaOperation;
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLOperation;
-import org.apache.tuscany.sca.invocation.Invoker;
-import org.apache.tuscany.sca.provider.ImplementationProvider;
-import org.apache.tuscany.sca.runtime.RuntimeComponent;
-import org.apache.tuscany.sca.runtime.RuntimeComponentService;
-
-/**
- * Implementation provider for Sample component implementations.
- *
- * @version $Rev$ $Date$
- */
-class SampleProvider implements ImplementationProvider {
- final RuntimeComponent comp;
- final SampleImplementation impl;
- final ProxyFactory pxf;
- Object instance;
-
- SampleProvider(final RuntimeComponent comp, final SampleImplementation impl, ProxyFactory pf) {
- this.comp = comp;
- this.impl = impl;
- this.pxf = pf;
- }
-
- public void start() {
- // Construct implementation instance and inject reference proxies
- try {
- instance = impl.clazz.newInstance();
-
- for(ComponentReference r: comp.getReferences()) {
- final Field f = impl.clazz.getDeclaredField(r.getName());
- f.setAccessible(true);
- // Inject a Java or WSDLReference proxy
- final Interface i = r.getInterfaceContract().getInterface();
- if(i instanceof JavaInterface)
- f.set(instance, pxf.createProxy(comp.getComponentContext().getServiceReference(f.getType(), r.getName())));
- else
- f.set(instance, new SampleWSDLProxy(r.getEndpointReferences().get(0), i));
- }
- } catch(Exception e) {
- throw new RuntimeException(e);
- }
- }
-
- public void stop() {
- instance = null;
- }
-
- public boolean supportsOneWayInvocation() {
- return false;
- }
-
- public Invoker createInvoker(final RuntimeComponentService s, final Operation op) {
- try {
- // Creating an invoker for a Java or WSDL-typed implementation
- if(op instanceof JavaOperation)
- return new SampleJavaInvoker((JavaOperation)op, impl.clazz, instance);
- return new SampleWSDLInvoker((WSDLOperation)op, impl.clazz, instance);
- } catch(Exception e) {
- throw new RuntimeException(e);
- }
- }
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProviderFactory.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProviderFactory.java
deleted file mode 100644
index 4ad24d33ff..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleProviderFactory.java
+++ /dev/null
@@ -1,48 +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 sample.impl;
-
-import org.apache.tuscany.sca.core.ExtensionPointRegistry;
-import org.apache.tuscany.sca.core.invocation.ExtensibleProxyFactory;
-import org.apache.tuscany.sca.core.invocation.ProxyFactory;
-import org.apache.tuscany.sca.provider.ImplementationProvider;
-import org.apache.tuscany.sca.provider.ImplementationProviderFactory;
-import org.apache.tuscany.sca.runtime.RuntimeComponent;
-
-/**
- * Factory for Sample implementation providers.
- *
- * @version $Rev$ $Date$
- */
-public class SampleProviderFactory implements ImplementationProviderFactory<SampleImplementation> {
- final ProxyFactory pxf;
-
- public SampleProviderFactory(final ExtensionPointRegistry ep) {
- pxf = ExtensibleProxyFactory.getInstance(ep);
- }
-
- public ImplementationProvider createImplementationProvider(final RuntimeComponent comp, final SampleImplementation impl) {
- return new SampleProvider(comp, impl, pxf);
- }
-
- public Class<SampleImplementation> getModelType() {
- return SampleImplementation.class;
- }
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLInvoker.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLInvoker.java
deleted file mode 100644
index 6c5317274f..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLInvoker.java
+++ /dev/null
@@ -1,56 +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 sample.impl;
-
-import java.lang.reflect.Method;
-
-import org.apache.tuscany.sca.interfacedef.wsdl.WSDLOperation;
-import org.apache.tuscany.sca.invocation.Invoker;
-import org.apache.tuscany.sca.invocation.Message;
-import org.w3c.dom.Element;
-
-/**
- * Invoker for Sample components that implement a WSDL interface using a generic
- * call method.
- *
- * @version $Rev$ $Date$
- */
-class SampleWSDLInvoker implements Invoker {
- final String name;
- final Object instance;
- final Method method;
-
- SampleWSDLInvoker(final WSDLOperation op, final Class<?> clazz, final Object instance) throws SecurityException, NoSuchMethodException {
- this.name = op.getName();
- this.instance = instance;
- this.method = clazz.getMethod("call", String.class, Element.class);
- }
-
- public Message invoke(final Message msg) {
- try {
- // Invoke the generic call method
- msg.setBody(method.invoke(instance, name, ((Object[])msg.getBody())[0]));
- } catch(Exception e) {
- e.printStackTrace();
- msg.setFaultBody(e.getCause());
- }
- return msg;
- }
-}
diff --git a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLProxy.java b/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLProxy.java
deleted file mode 100644
index a6882a0103..0000000000
--- a/sandbox/samples/temp/implementation-extension/src/main/java/sample/impl/SampleWSDLProxy.java
+++ /dev/null
@@ -1,57 +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 sample.impl;
-
-import java.lang.reflect.InvocationTargetException;
-import java.util.HashMap;
-import java.util.Map;
-
-import org.apache.tuscany.sca.assembly.EndpointReference;
-import org.apache.tuscany.sca.interfacedef.Interface;
-import org.apache.tuscany.sca.interfacedef.Operation;
-import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
-import org.w3c.dom.Element;
-
-import sample.api.WSDLReference;
-
-/**
- * Proxy used to call operations on WSDL references.
- */
-class SampleWSDLProxy implements WSDLReference {
- final RuntimeEndpointReference repr;
- final Map<String, Operation> ops;
-
- SampleWSDLProxy(EndpointReference epr, Interface wi) {
- repr = (RuntimeEndpointReference)epr;
- ops = new HashMap<String, Operation>();
- for(Operation o: wi.getOperations())
- ops.put(o.getName(), o);
- }
-
- @Override
- public Element call(String op, Element e) {
- try {
- // Invoke the named operation on the endpoint reference
- return (Element)repr.invoke(ops.get(op), new Object[] {e});
- } catch(InvocationTargetException ex) {
- throw new RuntimeException(ex);
- }
- }
-}