diff options
Diffstat (limited to 'sandbox/container.groovy/src/main/java/org')
13 files changed, 1013 insertions, 0 deletions
diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/config/AbstractContextFactory.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/config/AbstractContextFactory.java new file mode 100644 index 0000000000..cf0e722c62 --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/config/AbstractContextFactory.java @@ -0,0 +1,143 @@ +/**
+ *
+ * Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ * Licensed 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.container.extension.config;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.tuscany.core.builder.ContextFactory;
+import org.apache.tuscany.core.context.AtomicContext;
+import org.apache.tuscany.core.context.CompositeContext;
+import org.apache.tuscany.core.wire.SourceWireFactory;
+import org.apache.tuscany.core.wire.TargetWireFactory;
+import org.apache.tuscany.model.assembly.Scope;
+
+/**
+ * Abstract context factory.
+ */
+public abstract class AbstractContextFactory<T extends AtomicContext> implements ContextFactory<T> {
+
+ // Context scope
+ private Scope scope;
+
+ // Context name
+ private String name;
+
+ // SOurce proxy factories
+ private List<SourceWireFactory> sourceProxyFactories = new ArrayList<SourceWireFactory>();
+
+ // Target proxy factories
+ private Map<String, TargetWireFactory> targetProxyFactories = new HashMap<String, TargetWireFactory>();
+
+ /**
+ * Initializes the context factory.
+ *
+ * @param name Context name.
+ * @param scope Context scope.
+ * @param groovyScript Groovy script to run.
+ */
+ public AbstractContextFactory(String name, Scope scope) {
+ this.name = name;
+ this.scope = scope;
+ }
+
+ /**
+ * Returns the context scope.
+ * @return Context scope.
+ */
+ public final Scope getScope() {
+ return scope;
+ }
+
+ /**
+ * Returns the context name.
+ * @return Context name.
+ */
+ public final String getName() {
+ return name;
+ }
+
+ /**
+ * Adds a property.
+ *
+ * @param propertyName Property name.
+ * @param value Property value.
+ */
+ public final void addProperty(String propertyName, Object value) {
+ }
+
+ /**
+ * Adds a target proxy factory.
+ *
+ * @param serviceName Service name.
+ * @param factory Target proxy factory.
+ */
+ public final void addTargetWireFactory(String serviceName, TargetWireFactory factory) {
+ targetProxyFactories.put(serviceName, factory);
+ }
+
+ /**
+ * Gets a target proxy factory by name.
+ *
+ * @param serviceName Service name.
+ * @return Target wire factory for the specified service.
+ */
+ public final TargetWireFactory getTargetWireFactory(String serviceName) {
+ return targetProxyFactories.get(serviceName);
+ }
+
+ /**
+ * Returns all the target wire factories.
+ * @return All the target wire factories for the context.
+ */
+ public final Map<String, TargetWireFactory> getTargetWireFactories() {
+ return targetProxyFactories;
+ }
+
+ /**
+ * Adds a source wire factory.
+ *
+ * @param referenceName Reference name.
+ * @param factory SOurce wire factory.
+ */
+ public final void addSourceWireFactory(String referenceName, SourceWireFactory factory) {
+ sourceProxyFactories.add(factory);
+ }
+
+ /**
+ * Adds all source wire factories.
+ */
+ public final void addSourceWireFactories(String referenceName, Class referenceInterface, List<SourceWireFactory> factory, boolean multiplicity) {
+ sourceProxyFactories.addAll(factory);
+ }
+
+ /**
+ * Returns all the source wire factories.
+ */
+ public final List<SourceWireFactory> getSourceWireFactories() {
+ return sourceProxyFactories;
+ }
+
+ /**
+ * Notification that the parent factory has been activated.
+ */
+ public final void prepare(CompositeContext parent) {
+ }
+
+}
diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/context/AbstractComponentContext.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/context/AbstractComponentContext.java new file mode 100644 index 0000000000..866a233c66 --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/context/AbstractComponentContext.java @@ -0,0 +1,114 @@ +/**
+ *
+ * Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ * Licensed 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.container.extension.context;
+
+import java.util.Map;
+
+import org.apache.tuscany.core.context.AtomicContext;
+import org.apache.tuscany.core.context.CoreRuntimeException;
+import org.apache.tuscany.core.context.QualifiedName;
+import org.apache.tuscany.core.context.TargetException;
+import org.apache.tuscany.core.context.event.InstanceCreated;
+import org.apache.tuscany.core.context.impl.AbstractContext;
+import org.apache.tuscany.core.wire.ProxyCreationException;
+import org.apache.tuscany.core.wire.TargetWireFactory;
+import org.apache.tuscany.core.wire.WireFactory;
+
+/**
+ * Abstract component context.
+ *
+ */
+public abstract class AbstractComponentContext extends AbstractContext implements AtomicContext {
+
+ private Map<String, TargetWireFactory> targetProxyFactories;
+
+ public AbstractComponentContext(String name, Map<String, TargetWireFactory> targetProxyFactories) {
+ super(name);
+ this.targetProxyFactories = targetProxyFactories;
+ }
+
+ public Object getInstance(QualifiedName qName) throws TargetException {
+ return getInstance(qName, true);
+ }
+
+ /**
+ * Init method.
+ */
+ public void init() throws TargetException {
+ }
+
+ /**
+ * Detsroy method.
+ */
+ public void destroy() throws TargetException {
+ }
+
+ private synchronized Object getInstance(QualifiedName qName, boolean notify) throws TargetException {
+ String portName = qName.getPortName();
+ WireFactory targetFactory;
+ if (portName != null) {
+ targetFactory = targetProxyFactories.get(portName);
+ } else {
+ targetFactory = targetProxyFactories.values().iterator().next();
+ }
+ if (targetFactory == null) {
+ TargetException e = new TargetException("Target service not found");
+ e.setIdentifier(qName.getPortName());
+ e.addContextName(getName());
+ throw e;
+ }
+ try {
+ Object proxy = targetFactory.createProxy();
+ if (notify) {
+ publish(new InstanceCreated(this));
+ }
+ return proxy;
+ } catch (ProxyCreationException e) {
+ TargetException te = new TargetException("Error returning target", e);
+ e.setIdentifier(qName.getPortName());
+ e.addContextName(getName());
+ throw te;
+ }
+ }
+
+ /**
+ * Whether this context supports eager init.
+ */
+ public boolean isEagerInit() {
+ return false;
+ }
+
+ /**
+ * Whether this context is destroyable.
+ */
+ public boolean isDestroyable() {
+ return false;
+ }
+
+ /**
+ * Starts the context.
+ */
+ public void start() throws CoreRuntimeException {
+ }
+
+ /**
+ * Stops the context.
+ */
+ public void stop() throws CoreRuntimeException {
+ }
+
+}
diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/loader/AbstractImplementationLoader.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/loader/AbstractImplementationLoader.java new file mode 100644 index 0000000000..ed325e087b --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/extension/loader/AbstractImplementationLoader.java @@ -0,0 +1,160 @@ +/**
+ *
+ * Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ * Licensed 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.container.extension.loader;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
+
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+
+import org.apache.tuscany.core.config.ConfigurationLoadException;
+import org.apache.tuscany.core.config.InvalidRootElementException;
+import org.apache.tuscany.core.config.MissingResourceException;
+import org.apache.tuscany.core.config.SidefileLoadException;
+import org.apache.tuscany.core.loader.LoaderContext;
+import org.apache.tuscany.core.loader.StAXElementLoader;
+import org.apache.tuscany.core.loader.StAXLoaderRegistry;
+import org.apache.tuscany.core.loader.assembly.AssemblyConstants;
+import org.apache.tuscany.core.system.annotation.Autowire;
+import org.apache.tuscany.model.assembly.ComponentType;
+import org.apache.tuscany.model.assembly.Implementation;
+import org.osoa.sca.annotations.Scope;
+
+/**
+ * Abstract implementation loader.
+ *
+ */
+@Scope("MODULE")
+public abstract class AbstractImplementationLoader<T extends Implementation> implements StAXElementLoader<T> {
+
+ // Injected Stax loader registry.
+ protected StAXLoaderRegistry registry;
+
+ // XML input factory.
+ protected XMLInputFactory xmlFactory;
+
+ /**
+ * Initializes the XML input factory.
+ *
+ */
+ public AbstractImplementationLoader() {
+ xmlFactory = XMLInputFactory.newInstance();
+ }
+
+ /**
+ * Injection method for Stax loader registry.
+ * @param registry Stax loader registry.
+ */
+ @Autowire
+ public void setRegistry(StAXLoaderRegistry registry) {
+ this.registry = registry;
+ }
+
+ /**
+ * Loads the Groovy implementation.
+ *
+ * @param Stax XML stream reader.
+ * @param loaderContext Loader context.
+ * @return Groovy implementation.
+ */
+ public T load(XMLStreamReader reader, LoaderContext loaderContext) throws XMLStreamException, ConfigurationLoadException {
+
+ T assemblyObject = getAssemblyObject(reader, loaderContext);
+
+ URL componentTypeFile = getSideFile(reader, loaderContext);
+ ComponentType componentType = loadComponentType(componentTypeFile, loaderContext);
+
+ assemblyObject.setComponentType(componentType);
+
+ return assemblyObject;
+
+ }
+
+ /**
+ * Required to be implemented by the concrete classes.
+ * @return Implementation object.
+ */
+ protected abstract T getAssemblyObject(XMLStreamReader reader, LoaderContext loaderContext);
+
+ /**
+ * Gets the side file.
+ *
+ * @param reader Reader for the module file.
+ * @param loaderContext Loader context.
+ * @return Side file Url.
+ * @throws MissingResourceException
+ */
+ protected abstract URL getSideFile(XMLStreamReader reader, LoaderContext loaderContext) throws MissingResourceException;
+
+ /**
+ * Loads the SIDE file to get the component information.
+ *
+ * @param scriptFile SCript file name.
+ * @param loaderContext Loader context.
+ * @return Component information.
+ * @throws SidefileLoadException
+ * @throws MissingResourceException
+ */
+ private ComponentType loadComponentType(URL componentTypeFile, LoaderContext loaderContext) throws SidefileLoadException, MissingResourceException{
+
+ XMLStreamReader reader = null;
+ InputStream is = null;
+
+ try {
+ is = componentTypeFile.openStream();
+ reader = xmlFactory.createXMLStreamReader(is);
+ reader.nextTag();
+ if (!AssemblyConstants.COMPONENT_TYPE.equals(reader.getName())) {
+ InvalidRootElementException e = new InvalidRootElementException(AssemblyConstants.COMPONENT_TYPE, reader.getName());
+ e.setResourceURI(componentTypeFile.toString());
+ throw e;
+ }
+ return (ComponentType) registry.load(reader, loaderContext);
+ } catch (IOException e) {
+ SidefileLoadException sfe = new SidefileLoadException(e.getMessage());
+ sfe.setResourceURI(componentTypeFile.toString());
+ throw sfe;
+ } catch (XMLStreamException e) {
+ SidefileLoadException sfe = new SidefileLoadException(e.getMessage());
+ sfe.setResourceURI(componentTypeFile.toString());
+ throw sfe;
+ } catch (ConfigurationLoadException e) {
+ SidefileLoadException sfe = new SidefileLoadException(e.getMessage());
+ sfe.setResourceURI(componentTypeFile.toString());
+ throw sfe;
+ } finally {
+ try {
+ if(reader != null) {
+ reader.close();
+ }
+ } catch (XMLStreamException e) {
+ // ignore
+ }
+ try {
+ if(is != null) {
+ is.close();
+ }
+ } catch (IOException e) {
+ // ignore
+ }
+ }
+ }
+
+}
diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/assembly/GroovyImplementation.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/assembly/GroovyImplementation.java new file mode 100644 index 0000000000..6b39baefce --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/assembly/GroovyImplementation.java @@ -0,0 +1,64 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.assembly; + +import org.apache.tuscany.common.resource.ResourceLoader; +import org.apache.tuscany.model.assembly.impl.AtomicImplementationImpl; + +/** + * Meta-information for the Groovy implementation. + * + */ +public class GroovyImplementation extends AtomicImplementationImpl { + + // Full path of the script file to be executed + private String script; + + // Resource loader for accessing classpath resources + private ResourceLoader resourceLoader; + + /** + * Gets the full path of the script file to be executed. + * @return Full path of the script file to be executed. + */ + public String getScript() { + return script; + } + + /** + * Sets the full path of the script file to be executed. + * @param script Full path of the script file to be executed. + */ + public void setScript(String script) { + this.script = script; + } + + /** + * Gets the resource loader for accessing classpath resources. + * @return Resource loader. + */ + public ResourceLoader getResourceLoader() { return resourceLoader; } + + /** + * Sets the resource loader for accessing classpath resources. + * @param resourceLoader Resource loader. + */ + public void setResourceLoader(ResourceLoader resourceLoader) { + this.resourceLoader = resourceLoader; + } + +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/builder/GroovyContextFactoryBuilder.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/builder/GroovyContextFactoryBuilder.java new file mode 100644 index 0000000000..624af77241 --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/builder/GroovyContextFactoryBuilder.java @@ -0,0 +1,39 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.builder; + +import org.apache.tuscany.container.groovy.assembly.GroovyImplementation; +import org.apache.tuscany.container.groovy.config.GroovyContextFactory; +import org.apache.tuscany.container.groovy.invoker.GroovyScript; +import org.apache.tuscany.core.builder.ContextFactory; +import org.apache.tuscany.core.extension.ContextFactoryBuilderSupport; +import org.apache.tuscany.model.assembly.Scope; + +/** + * Groovy context factory builder. + * + */ +@org.osoa.sca.annotations.Scope("MODULE") +public class GroovyContextFactoryBuilder extends ContextFactoryBuilderSupport<GroovyImplementation> { + + @Override + protected ContextFactory createContextFactory(String componentName, GroovyImplementation implementation, Scope scope) { + GroovyScript groovyScript = new GroovyScript(implementation.getScript()); + return new GroovyContextFactory(componentName, scope, groovyScript); + } + +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/builder/GroovyTargetWireBuilder.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/builder/GroovyTargetWireBuilder.java new file mode 100644 index 0000000000..4939bd308d --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/builder/GroovyTargetWireBuilder.java @@ -0,0 +1,47 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.builder; + +import org.apache.tuscany.container.groovy.config.GroovyContextFactory; +import org.apache.tuscany.container.groovy.invoker.GroovyInvoker; +import org.apache.tuscany.core.context.QualifiedName; +import org.apache.tuscany.core.context.ScopeContext; +import org.apache.tuscany.core.extension.WireBuilderSupport; +import org.apache.tuscany.core.wire.TargetInvoker; +import org.osoa.sca.annotations.Scope; + +import java.lang.reflect.Method; + +/** + * Groovy target wire builder. + */ +@Scope("MODULE") +public class GroovyTargetWireBuilder extends WireBuilderSupport<GroovyContextFactory> { + + /** + * Created the invoker for groovy. + * + * @param targetName Target component name. + * @param method Method invoked on the proxy. + * @param context Scope context. + * @param downScope Flag for down scope. + */ + protected TargetInvoker createInvoker(QualifiedName targetName, Method method, ScopeContext context, boolean downScope) { + String serviceName = targetName.getPartName(); + return new GroovyInvoker(context, serviceName, method.getName()); + } +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/config/GroovyContextFactory.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/config/GroovyContextFactory.java new file mode 100644 index 0000000000..a5df33386e --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/config/GroovyContextFactory.java @@ -0,0 +1,55 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.config; + +import org.apache.tuscany.container.extension.config.AbstractContextFactory; +import org.apache.tuscany.container.groovy.context.GroovyComponentContext; +import org.apache.tuscany.container.groovy.invoker.GroovyScript; +import org.apache.tuscany.core.builder.ContextCreationException; +import org.apache.tuscany.model.assembly.Scope; + +/** + * Groovy context factory. + */ +public class GroovyContextFactory extends AbstractContextFactory<GroovyComponentContext> { + + // Groovy script to run + private GroovyScript groovyScript; + + /** + * Initializes the context factory. + * + * @param name Context name. + * @param scope Context scope. + * @param groovyScript Groovy script to run. + */ + public GroovyContextFactory(String name, Scope scope, GroovyScript groovyScript) { + super(name, scope); + this.groovyScript = groovyScript; + } + + /** + * Creates the Groovy component context. + */ + public GroovyComponentContext createContext() throws ContextCreationException { + return new GroovyComponentContext( + getName(), + getTargetWireFactories(), + groovyScript); + } + +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/context/GroovyComponentContext.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/context/GroovyComponentContext.java new file mode 100644 index 0000000000..254abcc709 --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/context/GroovyComponentContext.java @@ -0,0 +1,56 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.context; + +import java.util.Map; + +import org.apache.tuscany.container.extension.context.AbstractComponentContext; +import org.apache.tuscany.container.groovy.invoker.GroovyScript; +import org.apache.tuscany.core.context.TargetException; +import org.apache.tuscany.core.wire.TargetWireFactory; + +/** + * Groovy component context. + * + */ +public class GroovyComponentContext extends AbstractComponentContext { + + // Groovy script. + private GroovyScript groovyScript; + + /** + * Initializes the context. + * + * @param name Component name. + * @param targetProxyFactories Target wire factories. + * @param groovyScript Groovy script. + */ + public GroovyComponentContext(String name, + Map<String, TargetWireFactory> targetProxyFactories, + GroovyScript groovyScript) { + super(name, targetProxyFactories); + this.groovyScript = groovyScript; + } + + /** + * Gets the target invocation instance. + */ + public Object getTargetInstance() throws TargetException { + return groovyScript; + } + +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/invoker/GroovyInvoker.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/invoker/GroovyInvoker.java new file mode 100644 index 0000000000..0a478269bb --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/invoker/GroovyInvoker.java @@ -0,0 +1,108 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.invoker; + +import java.lang.reflect.InvocationTargetException; + +import org.apache.tuscany.core.context.AtomicContext; +import org.apache.tuscany.core.context.ScopeContext; +import org.apache.tuscany.core.message.Message; +import org.apache.tuscany.core.wire.Interceptor; +import org.apache.tuscany.core.wire.TargetInvoker; + +/** + * Groovy target invoker. + * + */ +public class GroovyInvoker implements TargetInvoker, Cloneable { + + // SCope context + private ScopeContext scopeContext; + + // Srevice name + private String serviceName; + + // Method name + private String methodName; + + /** + * Initializes the invoker. + * + * @param scopeContext SCope context. + * @param serviceName Service name. + * @param methodName Method name. + */ + public GroovyInvoker(ScopeContext scopeContext, String serviceName, String methodName) { + this.scopeContext = scopeContext; + this.serviceName = serviceName; + this.methodName = methodName; + } + + /** + * Invokes the target. + */ + public Object invokeTarget(Object payload) throws InvocationTargetException { + + AtomicContext atomicContext = (AtomicContext)scopeContext.getContext(serviceName); + GroovyScript groovyScript = (GroovyScript)atomicContext.getTargetInstance(); + + Object[] args = (Object[])payload; + + try { + return groovyScript.runScript(methodName, args); + } catch(Exception ex) { + throw new InvocationTargetException(ex); + } + + } + + /** + * Whether the invoker is cacheable. + */ + public boolean isCacheable() { + return false; + } + + /** + * Invokes the servce. + */ + public Message invoke(Message msg) { + try { + Object resp = invokeTarget(msg.getBody()); + msg.setBody(resp); + } catch (InvocationTargetException e) { + msg.setBody(e.getCause()); + } catch (Throwable e) { + msg.setBody(e); + } + return msg; + } + + /** + * Sets interceptor. + */ + public void setNext(Interceptor next) { + } + + /** + * Implementations must support deep cloning + */ + public Object clone() { + return new GroovyInvoker(scopeContext, serviceName, methodName); + } + +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/invoker/GroovyScript.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/invoker/GroovyScript.java new file mode 100644 index 0000000000..0e7445544c --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/invoker/GroovyScript.java @@ -0,0 +1,61 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.invoker; + +import org.codehaus.groovy.control.CompilationFailedException; + +import groovy.lang.GroovyClassLoader; +import groovy.lang.GroovyObject; + +/** + * Models a Groovy script. + */ +public class GroovyScript { + + // Script to run. + private String script; + + /** + * Initializes the script name. + * @param script Full path to the script. + */ + public GroovyScript(String script) { + this.script = script; + } + + /** + * Executes the script. + * @param methodName Name of the method to be executed. + * @param args Arguments to the method. + * @return Result of invocation. + * @throws CompilationFailedException + * @throws InstantiationException + * @throws IllegalAccessException + */ + public Object runScript(String methodName, Object[] args) throws CompilationFailedException, InstantiationException, IllegalAccessException { + + ClassLoader parent = getClass().getClassLoader(); + GroovyClassLoader loader = new GroovyClassLoader(parent); + + Class groovyClass = loader.parseClass(parent.getResourceAsStream(script)); + + GroovyObject groovyObject = (GroovyObject) groovyClass.newInstance(); + return groovyObject.invokeMethod(methodName, args); + + } + +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/loader/GroovyImplementationLoader.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/loader/GroovyImplementationLoader.java new file mode 100644 index 0000000000..b2034808d4 --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/container/groovy/loader/GroovyImplementationLoader.java @@ -0,0 +1,97 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.container.groovy.loader; + +import java.net.URL; + +import javax.xml.namespace.QName; +import javax.xml.stream.XMLStreamReader; + +import org.apache.tuscany.container.extension.loader.AbstractImplementationLoader; +import org.apache.tuscany.container.groovy.assembly.GroovyImplementation; +import org.apache.tuscany.core.config.MissingResourceException; +import org.apache.tuscany.core.loader.LoaderContext; +import org.osoa.sca.annotations.Destroy; +import org.osoa.sca.annotations.Init; +import org.osoa.sca.annotations.Scope; + +/** + * Groovy implementation loader. + * + */ +@Scope("MODULE") +public class GroovyImplementationLoader extends AbstractImplementationLoader<GroovyImplementation> { + + // Qualified name for the Groovy implementation. + public static final QName NAME = new QName("http://org.apache.tuscany/xmlns/groovy/0.9", "implementation.groovy"); + + /** + * Lifecycle method registers the implementation loader. + * + */ + @Init(eager = true) + public void start() { + registry.registerLoader(NAME, this); + } + + /** + * Lifecycle method deregisters the implementation loader. + * + */ + @Destroy + public void stop() { + registry.unregisterLoader(NAME, this); + } + + /** + * Required to be implemented by the concrete classes. + * @return Implementation object. + */ + protected GroovyImplementation getAssemblyObject(XMLStreamReader reader, LoaderContext loaderContext) { + + GroovyImplementation groovyImplementation = new GroovyImplementation(); + String script = reader.getAttributeValue(null, "script"); + + groovyImplementation.setScript(script); + groovyImplementation.setResourceLoader(loaderContext.getResourceLoader()); + + return groovyImplementation; + + } + + /** + * Gets the side file. + * + * @param reader Reader for the module file. + * @param loaderContext Loader context. + * @return Side file Url. + * @throws MissingResourceException + */ + protected URL getSideFile(XMLStreamReader reader, LoaderContext loaderContext) + throws MissingResourceException { + + String script = reader.getAttributeValue(null, "script"); + String sidefile = script.substring(0, script.lastIndexOf('.')) + ".componentType"; + URL componentTypeFile = loaderContext.getResourceLoader().getResource(sidefile); + if (componentTypeFile == null) { + throw new MissingResourceException(sidefile); + } + return componentTypeFile; + + } + +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/samples/groovy/Greeting.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/samples/groovy/Greeting.java new file mode 100644 index 0000000000..61eb4bce00 --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/samples/groovy/Greeting.java @@ -0,0 +1,6 @@ +package org.apache.tuscany.samples.groovy; + +public interface Greeting { + + void greet(String name); +} diff --git a/sandbox/container.groovy/src/main/java/org/apache/tuscany/samples/groovy/GreetingClient.java b/sandbox/container.groovy/src/main/java/org/apache/tuscany/samples/groovy/GreetingClient.java new file mode 100644 index 0000000000..8c2c5134cc --- /dev/null +++ b/sandbox/container.groovy/src/main/java/org/apache/tuscany/samples/groovy/GreetingClient.java @@ -0,0 +1,63 @@ +/** + * + * Copyright 2005 The Apache Software Foundation or its licensors, as applicable. + * + * Licensed 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.samples.groovy; + +import java.util.logging.Level; +import java.util.logging.LogManager; +import java.util.Properties; + +import org.osoa.sca.CurrentModuleContext; +import org.osoa.sca.ModuleContext; + +import org.apache.tuscany.core.client.TuscanyRuntime; +import org.apache.tuscany.common.monitor.MonitorFactory; +import org.apache.tuscany.common.monitor.impl.JavaLoggingMonitorFactory; + +/** + * This client program shows how to create an SCA runtime, start it, + * locate a simple groovy service component and invoke it. + */ +public class GreetingClient { + + public static final void main(String[] args) throws Exception { + + // Setup Tuscany monitoring to use java.util.logging + LogManager.getLogManager().readConfiguration(GreetingClient.class.getResourceAsStream("/logging.properties")); + Properties levels = new Properties(); + MonitorFactory monitorFactory = new JavaLoggingMonitorFactory(levels, Level.FINEST, "MonitorMessages"); + + // Obtain Tuscany runtime + TuscanyRuntime tuscany = new TuscanyRuntime("greeting", null, monitorFactory); + + // Associate the application module component with this thread + tuscany.start(); + + // Obtain SCA module context. + ModuleContext moduleContext = CurrentModuleContext.getContext(); + + Greeting greeting = (Greeting) moduleContext.locateService("GreetingComponent"); + greeting.greet("World"); + + System.err.flush(); + + // Disassociate the application module component + tuscany.stop(); + + // Shut down the runtime + tuscany.shutdown(); + } +} |