From 235297946b4e82b74ac6173352b85ecd80be6017 Mon Sep 17 00:00:00 2001 From: slaws Date: Thu, 9 Sep 2010 15:55:07 +0000 Subject: Start separate nodes from separate mainlines. git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@995477 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/reporting/JSELauncheCalculator.java | 333 +++++++++++++++++++++ .../src/main/java/reporting/JSELauncherAdd.java | 144 +++++++++ .../reporting/src/main/resources/node-add.xml | 34 +++ .../src/main/resources/node-calculator.xml | 34 +++ .../reporting/JSELauncherReportingTestCase.java | 2 +- 5 files changed, 546 insertions(+), 1 deletion(-) create mode 100644 sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncheCalculator.java create mode 100644 sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncherAdd.java create mode 100644 sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-add.xml create mode 100644 sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-calculator.xml (limited to 'sca-java-2.x') diff --git a/sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncheCalculator.java b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncheCalculator.java new file mode 100644 index 0000000000..25729ea1ea --- /dev/null +++ b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncheCalculator.java @@ -0,0 +1,333 @@ +/* + * 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 reporting; + +import java.io.ByteArrayOutputStream; +import java.io.File; +import java.io.StringWriter; +import java.net.URI; +import java.util.List; +import java.util.Map; +import java.util.Properties; + +import javax.xml.stream.XMLInputFactory; +import javax.xml.stream.XMLOutputFactory; +import javax.xml.stream.XMLStreamWriter; + +import org.apache.tuscany.sca.assembly.Binding; +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.Endpoint; +import org.apache.tuscany.sca.assembly.EndpointReference; +import org.apache.tuscany.sca.contribution.Artifact; +import org.apache.tuscany.sca.contribution.processor.ExtensibleStAXArtifactProcessor; +import org.apache.tuscany.sca.contribution.processor.ProcessorContext; +import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; +import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessorExtensionPoint; +import org.apache.tuscany.sca.core.ExtensionPointRegistry; +import org.apache.tuscany.sca.core.FactoryExtensionPoint; +import org.apache.tuscany.sca.core.assembly.impl.RuntimeEndpointImpl; +import org.apache.tuscany.sca.core.assembly.impl.RuntimeEndpointReferenceImpl; +import org.apache.tuscany.sca.definitions.Definitions; +import org.apache.tuscany.sca.deployment.Deployer; +import org.apache.tuscany.sca.invocation.Interceptor; +import org.apache.tuscany.sca.invocation.InvocationChain; +import org.apache.tuscany.sca.invocation.Invoker; +import org.apache.tuscany.sca.node.Contribution; +import org.apache.tuscany.sca.node.Node; +import org.apache.tuscany.sca.node.NodeFactory; +import org.apache.tuscany.sca.node.configuration.ContributionConfiguration; +import org.apache.tuscany.sca.node.configuration.NodeConfiguration; +import org.apache.tuscany.sca.node.impl.NodeFactoryImpl; +import org.apache.tuscany.sca.node.impl.NodeImpl; +import org.apache.tuscany.sca.runtime.DomainRegistryFactory; +import org.apache.tuscany.sca.runtime.EndpointRegistry; +import org.apache.tuscany.sca.runtime.ExtensibleDomainRegistryFactory; +import org.junit.AfterClass; +import org.junit.BeforeClass; +import org.junit.Test; + +import com.sun.jmx.remote.util.Service; +import com.sun.xml.internal.txw2.output.IndentingXMLStreamWriter; + +import calculator.CalculatorService; + +/** + * This client program shows how to extract useful(?) information from the Tuscany SCA runtime + */ +public class JSELauncheCalculator { + + private static NodeFactory nodeFactory; + private static Node node1; + private static Node node2; + private static CalculatorService calculator; + + + public static void main(String[] args) throws Exception { + JSELauncheCalculator launcher = new JSELauncheCalculator(); + launcher.setUp(); + + launcher.callCalulator(); + launcher.listExtensions(); + launcher.listNodes(); + launcher.listNodeConfigurations(); + launcher.listContributions(); + launcher.listDomainComposite(); + launcher.listDomainDefinitions(); + launcher.listEndpoints(); + launcher.listWires(); + + launcher.tearDown(); + } + + @BeforeClass + public static void setUp() throws Exception { + try { +/* new + org.apache.tuscany.sca.node2.NodeFactory nodeFactoryNew = org.apache.tuscany.sca.node2.NodeFactory.newInstance(); + + org.apache.tuscany.sca.node2.Node node2New = nodeFactoryNew.createNode(); + node2New.installContribution("../domain/distributed-calculator/contribution-calculator/target/classes"); + + calculator = node2New.getService(CalculatorService.class, "CalculatorServiceComponent"); +*/ + +/* old */ + // TUSCANY-3675 - push hazelcast config into factory as adding it to URI doesn't work + Properties properties = new Properties(); + properties.setProperty("bind", "192.168.0.2"); + nodeFactory = NodeFactory.newInstance(properties); + + // TUSCANY-3675 - push hazelcast config into factory as adding it to URI doesn't work + //node2 = nodeFactory.createNode(new Contribution("c1", "../domain/distributed-calculator/contribution-calculator/target/classes")); + //node2 = nodeFactory.createNode(URI.create("tuscany:default?listen=127.0.0.1:14820"), "../domain/distributed-calculator/contribution-calculator/target/classes"); + //node2 = nodeFactory.createNode(URI.create("tuscany:default"), "../domain/distributed-calculator/contribution-calculator/target/classes"); + node2 = nodeFactory.createNode(new File("./target/classes/node-calculator.xml").toURL()); + + node2.start(); + + calculator = node2.getService(CalculatorService.class, "CalculatorServiceComponent"); + + } catch (Exception ex){ + ex.printStackTrace(); + } + } + + @AfterClass + public static void tearDown() throws Exception { + node2.stop(); + } + + @Test + public void callCalulator(){ + printTestName("callCalulator"); + double result = calculator.add(3, 2); + System.out.println("3 + 2 = " + result); + } + + @Test + public void listExtensions(){ + printTestName("listExtensions"); + // TODO + } + + @Test + public void listNodes(){ + printTestName("listNodes"); + Map nodes = ((NodeFactoryImpl)nodeFactory).getNodes(); + for (Object nodeKey : nodes.keySet()){ + System.out.println(nodeKey); + } + } + + @Test + public void listNodeConfigurations(){ + printTestName("listNodeConfigurations"); + Map nodes = ((NodeFactoryImpl)nodeFactory).getNodes(); + for (Node node : nodes.values()){ + System.out.println("Node: " + ((NodeImpl)node).getURI()); + printXML(((NodeImpl)node).getConfiguration()); + } + } + + @Test + public void listContributions(){ + printTestName("listContributions"); + Map nodes = ((NodeFactoryImpl)nodeFactory).getNodes(); + for (Node node : nodes.values()){ + System.out.println("Node: " + ((NodeImpl)node).getURI()); + NodeConfiguration nodeConfiguration = ((NodeImpl)node).getConfiguration(); + for (org.apache.tuscany.sca.contribution.Contribution contribution : ((NodeImpl)node).getContributions()){ + System.out.println("Contribution: " + contribution.getURI() + " location " + contribution.getLocation()); + for (Artifact artifact : contribution.getArtifacts()){ + System.out.println(" Artifact: " + artifact.getURI() + " location " + artifact.getLocation()); + } + } + } + } + + @Test + public void listDomainComposite(){ + printTestName("listDomainComposite"); + Map nodes = ((NodeFactoryImpl)nodeFactory).getNodes(); + for (Node node : nodes.values()){ + System.out.println("Node: " + ((NodeImpl)node).getURI()); + printXML(((NodeImpl)node).getDomainComposite()); + } + } + + @Test + public void listDomainDefinitions(){ + printTestName("listDomainDefinitions"); + Deployer deployer = ((NodeFactoryImpl)nodeFactory).getDeployer(); + Definitions systemDefinitions = deployer.getSystemDefinitions(); + printXML(systemDefinitions); + } + + @Test + public void listEndpoints(){ + printTestName("listEndpoints"); + ExtensionPointRegistry registry = ((NodeFactoryImpl)nodeFactory).getExtensionPointRegistry(); + Map nodes = ((NodeFactoryImpl)nodeFactory).getNodes(); + Node firstNode = nodes.values().iterator().next(); + NodeConfiguration firstNodeConfig = ((NodeImpl)firstNode).getConfiguration(); + + DomainRegistryFactory domainRegistryFactory = ExtensibleDomainRegistryFactory.getInstance(registry); + // TODO - I don't understand where the scheme gets set/used + EndpointRegistry endpointRegistry = domainRegistryFactory.getEndpointRegistry("vm:" + firstNodeConfig.getDomainRegistryURI(), firstNodeConfig.getDomainURI()); + + for (Endpoint endpoint : endpointRegistry.getEndpoints()){ + System.out.println(endpoint); + printEndpointXML(endpoint); + } + } + + @Test + public void listWires(){ + printTestName("listWires"); + Map nodes = ((NodeFactoryImpl)nodeFactory).getNodes(); + for (Node node : nodes.values()){ + System.out.println("Node: " + ((NodeImpl)node).getURI()); + listComponentWires(((NodeImpl)node).getDomainComposite()); + } + } + + // utils + + private void listComponentWires(Composite composite){ + for(Component component : composite.getComponents()){ + if (component.getImplementation() instanceof Composite){ + listComponentWires((Composite)component.getImplementation()); + } + System.out.println(" Component: " + component.getName()); + + for(ComponentService service : component.getServices()){ + System.out.println(" Service: " + service.getName()); + for(Endpoint endpoint : service.getEndpoints()){ + System.out.println(" Endpoint: " + endpoint); + System.out.println(" Binding: " + endpoint.getBinding().getType()); + printInvocationChains(((RuntimeEndpointImpl)endpoint).getInvocationChains()); + } + } + for(ComponentReference reference : component.getReferences()){ + System.out.println(" Reference: " + reference.getName()); + for(EndpointReference endpointReference : reference.getEndpointReferences()){ + System.out.println(" EndpointReference: " + endpointReference); + Binding binding = endpointReference.getBinding(); + if (binding != null){ + System.out.println(" Binding: " + binding.getType()); + printInvocationChains(((RuntimeEndpointReferenceImpl)endpointReference).getInvocationChains()); + } + } + } + } + } + + private void printInvocationChains(List chains){ + for(InvocationChain chain : chains){ + System.out.println(" Operation: " + chain.getTargetOperation().getName()); + Invoker invoker = chain.getHeadInvoker(); + while(invoker != null){ + System.out.println(" Invoker: " + invoker.getClass().getName()); + if (invoker instanceof Interceptor){ + invoker = ((Interceptor)invoker).getNext(); + } else { + invoker = null; + } + } + } + } + + private void printTestName(String name){ + System.out.println("====================================================================="); + System.out.println(name); + System.out.println("====================================================================="); + } + + private void printXML(Object model){ + try { + ExtensionPointRegistry registry = ((NodeFactoryImpl)nodeFactory).getExtensionPointRegistry(); + XMLInputFactory inputFactory = XMLInputFactory.newInstance(); + + StAXArtifactProcessorExtensionPoint xmlProcessors = registry.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class); + StAXArtifactProcessor xmlProcessor = new ExtensibleStAXArtifactProcessor(xmlProcessors, inputFactory, null); + + ProcessorContext context = new ProcessorContext(registry); + + ByteArrayOutputStream bos = new ByteArrayOutputStream(); + XMLOutputFactory outputFactory = registry.getExtensionPoint(FactoryExtensionPoint.class).getFactory(XMLOutputFactory.class); + XMLStreamWriter writer = new IndentingXMLStreamWriter(outputFactory.createXMLStreamWriter(bos)); + + xmlProcessor.write(model, writer, context); + writer.flush(); + + System.out.println(bos.toString()); + } catch(Exception ex) { + ex.printStackTrace(); + } + } + + // TODO - we don't have a processor registered for RuntimeEndpointImpl? + private void printEndpointXML(Endpoint model){ + try { + ExtensionPointRegistry registry = ((NodeFactoryImpl)nodeFactory).getExtensionPointRegistry(); + XMLInputFactory inputFactory = XMLInputFactory.newInstance(); + + StAXArtifactProcessorExtensionPoint xmlProcessors = registry.getExtensionPoint(StAXArtifactProcessorExtensionPoint.class); + StAXArtifactProcessor xmlProcessor = xmlProcessors.getProcessor(Endpoint.class); + + ProcessorContext context = new ProcessorContext(registry); + + ByteArrayOutputStream bos = new ByteArrayOutputStream(); + XMLOutputFactory outputFactory = registry.getExtensionPoint(FactoryExtensionPoint.class).getFactory(XMLOutputFactory.class); + XMLStreamWriter writer = new IndentingXMLStreamWriter(outputFactory.createXMLStreamWriter(bos)); + + xmlProcessor.write(model, writer, context); + writer.flush(); + + System.out.println(bos.toString()); + } catch(Exception ex) { + ex.printStackTrace(); + } + } + +} diff --git a/sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncherAdd.java b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncherAdd.java new file mode 100644 index 0000000000..5351ed263b --- /dev/null +++ b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/java/reporting/JSELauncherAdd.java @@ -0,0 +1,144 @@ +/* + * 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 reporting; + +import java.io.ByteArrayOutputStream; +import java.io.File; +import java.io.StringWriter; +import java.net.URI; +import java.net.URL; +import java.util.List; +import java.util.Map; +import java.util.Properties; + +import javax.xml.stream.XMLInputFactory; +import javax.xml.stream.XMLOutputFactory; +import javax.xml.stream.XMLStreamWriter; + +import org.apache.tuscany.sca.assembly.Binding; +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.Endpoint; +import org.apache.tuscany.sca.assembly.EndpointReference; +import org.apache.tuscany.sca.contribution.Artifact; +import org.apache.tuscany.sca.contribution.processor.ExtensibleStAXArtifactProcessor; +import org.apache.tuscany.sca.contribution.processor.ProcessorContext; +import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; +import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessorExtensionPoint; +import org.apache.tuscany.sca.core.DefaultExtensionPointRegistry; +import org.apache.tuscany.sca.core.ExtensionPointRegistry; +import org.apache.tuscany.sca.core.FactoryExtensionPoint; +import org.apache.tuscany.sca.core.UtilityExtensionPoint; +import org.apache.tuscany.sca.core.assembly.impl.RuntimeEndpointImpl; +import org.apache.tuscany.sca.core.assembly.impl.RuntimeEndpointReferenceImpl; +import org.apache.tuscany.sca.definitions.Definitions; +import org.apache.tuscany.sca.deployment.Deployer; +import org.apache.tuscany.sca.invocation.Interceptor; +import org.apache.tuscany.sca.invocation.InvocationChain; +import org.apache.tuscany.sca.invocation.Invoker; +import org.apache.tuscany.sca.node.Contribution; +import org.apache.tuscany.sca.node.Node; +import org.apache.tuscany.sca.node.NodeFactory; +import org.apache.tuscany.sca.node.configuration.ContributionConfiguration; +import org.apache.tuscany.sca.node.configuration.NodeConfiguration; +import org.apache.tuscany.sca.node.impl.NodeFactoryImpl; +import org.apache.tuscany.sca.node.impl.NodeImpl; +import org.apache.tuscany.sca.runtime.DomainRegistryFactory; +import org.apache.tuscany.sca.runtime.EndpointRegistry; +import org.apache.tuscany.sca.runtime.ExtensibleDomainRegistryFactory; +import org.apache.tuscany.sca.runtime.RuntimeProperties; +import org.junit.AfterClass; +import org.junit.BeforeClass; +import org.junit.Ignore; +import org.junit.Test; + +import com.sun.jmx.remote.util.Service; +import com.sun.xml.internal.txw2.output.IndentingXMLStreamWriter; + +import calculator.CalculatorService; + +/** + * This client program shows how to extract useful(?) information from the Tuscany SCA runtime + */ +public class JSELauncherAdd { + + private static NodeFactory nodeFactory; + private static Node node1; + private static Node node2; + private static CalculatorService calculator; + + + public static void main(String[] args) throws Exception { + JSELauncherAdd launcher = new JSELauncherAdd (); + launcher.setUp(); + + launcher.waitForInput(); + + launcher.tearDown(); + } + + @BeforeClass + public static void setUp() throws Exception { + try { +/* new + org.apache.tuscany.sca.node2.NodeFactory nodeFactoryNew = org.apache.tuscany.sca.node2.NodeFactory.newInstance(); + org.apache.tuscany.sca.node2.Node node1New = nodeFactoryNew.createNode(); + node1New.installContribution("../domain/distributed-calculator/contribution-add/target/classes"); + +*/ + +/* old */ + // TUSCANY-3675 - push hazelcast config into factory as adding it to URI doesn't work + Properties properties = new Properties(); + properties.setProperty("bind", "192.168.0.2"); + nodeFactory = NodeFactory.newInstance(properties); + + // TUSCANY-3675 - push hazelcast config into factory as adding it to URI doesn't work + //node1 = nodeFactory.createNode(new Contribution("c1", "../domain/distributed-calculator/contribution-add/target/classes")); + //node1 = nodeFactory.createNode(URI.create("tuscany:default?listen=127.0.0.1:14820"), "../domain/distributed-calculator/contribution-add/target/classes"); + //node1 = nodeFactory.createNode(URI.create("tuscany:default"), "../domain/distributed-calculator/contribution-add/target/classes"); + node1 = nodeFactory.createNode(new File("./target/classes/node-add.xml").toURL()); + + node1.start(); + + } catch (Exception ex){ + ex.printStackTrace(); + } + } + + @AfterClass + public static void tearDown() throws Exception { + node1.stop(); + } + + @Test + @Ignore + public void waitForInput(){ + System.out.println("Press key to end"); + try { + System.in.read(); + } catch(Exception ex){ + // do nothing + } + } + +} diff --git a/sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-add.xml b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-add.xml new file mode 100644 index 0000000000..7a4a6d5695 --- /dev/null +++ b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-add.xml @@ -0,0 +1,34 @@ + + + + + + + + + + + + \ No newline at end of file diff --git a/sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-calculator.xml b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-calculator.xml new file mode 100644 index 0000000000..31098b129d --- /dev/null +++ b/sca-java-2.x/trunk/contrib/samples/reporting/src/main/resources/node-calculator.xml @@ -0,0 +1,34 @@ + + + + + + + + + + + + \ No newline at end of file diff --git a/sca-java-2.x/trunk/contrib/samples/reporting/src/test/java/reporting/JSELauncherReportingTestCase.java b/sca-java-2.x/trunk/contrib/samples/reporting/src/test/java/reporting/JSELauncherReportingTestCase.java index 51221ee7b5..b4cc8fa3ee 100644 --- a/sca-java-2.x/trunk/contrib/samples/reporting/src/test/java/reporting/JSELauncherReportingTestCase.java +++ b/sca-java-2.x/trunk/contrib/samples/reporting/src/test/java/reporting/JSELauncherReportingTestCase.java @@ -80,7 +80,7 @@ public class JSELauncherReportingTestCase { public static void main(String[] args) throws Exception { - JSELauncherReportingTestCase launcher = new JSELauncherReportingTestCase (); + JSELauncherReportingTestCase launcher = new JSELauncherReportingTestCase(); launcher.setUp(); launcher.callCalulator(); -- cgit v1.2.3