diff options
| author | jsdelfino <jsdelfino@13f79535-47bb-0310-9956-ffa450edef68> | 2010-07-02 22:02:39 +0000 |
|---|---|---|
| committer | jsdelfino <jsdelfino@13f79535-47bb-0310-9956-ffa450edef68> | 2010-07-02 22:02:39 +0000 |
| commit | 1890fd58ebfb9e82157337fe312842b22cd97fb1 (patch) | |
| tree | 29b49cbf534b1287f4e818aabead5327a8409829 | |
| parent | fccdd6a87c4e9961153eb52e9b2b9f614ebb9724 (diff) | |
Add a sample shell program useful to start and stop SCA composites interactively.
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@960122 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to '')
6 files changed, 290 insertions, 0 deletions
diff --git a/sca-java-2.x/trunk/samples/launcher-shell/README b/sca-java-2.x/trunk/samples/launcher-shell/README new file mode 100644 index 0000000000..2b5c62ce13 --- /dev/null +++ b/sca-java-2.x/trunk/samples/launcher-shell/README @@ -0,0 +1,31 @@ +Sample Tuscany Shell
+====================
+
+This directory contains a sample shell program supporting simple commands to
+start and stop SCA composites.
+
+To build the sample shell do this:
+mvn install
+mvn dependency copy-dependencies
+
+To run it:
+./sca
+
+at the prompt:
+start myNode mySampleContrib ../contribution-implementation-java-calculator/target/classes
+
+or:
+start myNode mySampleContrib http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar
+
+also try:
+status
+stop myNode
+bye
+
+Starting and stopping composites is pretty fast. To see that, try the following
+two scripts, which start/stop a sample composite 10 times.
+
+./sca <sca-test
+or
+./sca <sca-test-remote
+
diff --git a/sca-java-2.x/trunk/samples/launcher-shell/pom.xml b/sca-java-2.x/trunk/samples/launcher-shell/pom.xml new file mode 100644 index 0000000000..ee1e0c1137 --- /dev/null +++ b/sca-java-2.x/trunk/samples/launcher-shell/pom.xml @@ -0,0 +1,76 @@ +<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ * 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.
+-->
+<project>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-sca</artifactId>
+ <version>2.0-SNAPSHOT</version>
+ <relativePath>../../pom.xml</relativePath>
+ </parent>
+ <artifactId>sample-launcher-shell</artifactId>
+ <name>Apache Tuscany SCA Sample Launcher Shell</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-feature-api</artifactId>
+ <type>pom</type>
+ <version>2.0-SNAPSHOT</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-feature-core</artifactId>
+ <type>pom</type>
+ <version>2.0-SNAPSHOT</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-feature-webservice</artifactId>
+ <type>pom</type>
+ <version>2.0-SNAPSHOT</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-feature-ejava</artifactId>
+ <type>pom</type>
+ <version>2.0-SNAPSHOT</version>
+ </dependency>
+
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.8.1</version>
+ <scope>test</scope>
+ </dependency>
+
+ </dependencies>
+
+ <build>
+ <finalName>${artifactId}</finalName>
+
+ <plugins>
+
+ </plugins>
+ </build>
+</project>
diff --git a/sca-java-2.x/trunk/samples/launcher-shell/sca b/sca-java-2.x/trunk/samples/launcher-shell/sca new file mode 100755 index 0000000000..2c049721d4 --- /dev/null +++ b/sca-java-2.x/trunk/samples/launcher-shell/sca @@ -0,0 +1,2 @@ +#!/bin/bash +java -classpath `find target -name "*.jar" | awk '{ printf "%s:", $1 }'` sample.Shell diff --git a/sca-java-2.x/trunk/samples/launcher-shell/sca-test b/sca-java-2.x/trunk/samples/launcher-shell/sca-test new file mode 100644 index 0000000000..eb6f059a3d --- /dev/null +++ b/sca-java-2.x/trunk/samples/launcher-shell/sca-test @@ -0,0 +1,20 @@ +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo +start foo c1 ../contribution-implementation-java-calculator/target/classes +stop foo diff --git a/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote b/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote new file mode 100644 index 0000000000..32838300bf --- /dev/null +++ b/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote @@ -0,0 +1,20 @@ +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo +start foo c1 http://people.apache.org/~jsdelfino/tuscany/java/test/sample-contribution-binding-ws-calculator.jar +stop foo diff --git a/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java b/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java new file mode 100644 index 0000000000..776b07e344 --- /dev/null +++ b/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java @@ -0,0 +1,141 @@ +/*
+ * 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;
+
+import static java.lang.System.in;
+import static java.lang.System.out;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.concurrent.Callable;
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.IOException;
+import org.apache.tuscany.sca.node.Contribution;
+import org.apache.tuscany.sca.node.Node;
+import org.apache.tuscany.sca.node.NodeFactory;
+
+
+/**
+ * A little SCA command shell.
+ */
+public class Shell {
+ final NodeFactory nodeFactory = NodeFactory.newInstance();
+
+ public static class NodeInfo {
+ final String name;
+ final String curi;
+ final String cloc;
+ final Node node;
+
+ NodeInfo(final String name, final String curi, final String cloc, final Node node) {
+ this.name = name;
+ this.curi = curi;
+ this.cloc = cloc;
+ this.node = node;
+ }
+
+ public String toString() {
+ return name + " " + curi + " " + cloc;
+ }
+ }
+ final Map<String, NodeInfo> nodes = new HashMap<String, NodeInfo>();
+
+ final List<String> history = new ArrayList<String>();
+
+ public static void main(final String[] args) throws Exception {
+ new Shell().run();
+ }
+
+ boolean start(final String name, final String curi, final String cloc) {
+ final Node node = nodeFactory.createNode(new Contribution(curi, cloc));
+ nodes.put(name, new NodeInfo(name, curi, cloc, node));
+ node.start();
+ return true;
+ }
+
+ boolean stop(final String name) {
+ nodes.get(name).node.stop();
+ nodes.remove(name);
+ return true;
+ }
+
+ boolean status() {
+ out.println(nodes.values());
+ return true;
+ }
+
+ boolean history() {
+ for (String l: history)
+ out.println(l);
+ return true;
+ }
+
+ static boolean bye() {
+ return false;
+ }
+
+ List<String> read(final BufferedReader r) throws IOException {
+ out.print("=> ");
+ final String l = r.readLine();
+ history.add(l);
+ return Arrays.asList(l != null? l.split(" ") : "bye".split(" "));
+ }
+
+ Callable<Boolean> eval(final List<String> toks) {
+ final String op = toks.get(0);
+ if (op.equals("start")) return new Callable<Boolean>() { public Boolean call() {
+ return start(toks.get(1), toks.get(2), toks.get(3));
+ }};
+ if (op.equals("stop")) return new Callable<Boolean>() { public Boolean call() {
+ return stop(toks.get(1));
+ }};
+ if (op.equals("status")) return new Callable<Boolean>() { public Boolean call() {
+ return status();
+ }};
+ if (op.equals("history")) return new Callable<Boolean>() { public Boolean call() {
+ return history();
+ }};
+ if (op.equals("bye")) return new Callable<Boolean>() { public Boolean call() {
+ return bye();
+ }};
+ return new Callable<Boolean>() { public Boolean call() {
+ return true;
+ }};
+ }
+
+ boolean apply(final Callable<Boolean> func) {
+ try {
+ return func.call();
+ } catch (Exception e) {
+ e.printStackTrace();
+ return true;
+ }
+ }
+
+ public Map<String, NodeInfo> run() throws IOException {
+ final BufferedReader r = new BufferedReader(new InputStreamReader(in));
+ while(apply(eval(read(r))));
+ return nodes;
+ }
+}
|