You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by js...@apache.org on 2010/07/03 00:02:40 UTC
svn commit: r960122 - in /tuscany/sca-java-2.x/trunk/samples/launcher-shell:
./ README pom.xml sca sca-test sca-test-remote src/ src/main/
src/main/java/ src/main/java/sample/ src/main/java/sample/Shell.java
Author: jsdelfino
Date: Fri Jul 2 22:02:39 2010
New Revision: 960122
URL: http://svn.apache.org/viewvc?rev=960122&view=rev
Log:
Add a sample shell program useful to start and stop SCA composites interactively.
Added:
tuscany/sca-java-2.x/trunk/samples/launcher-shell/
tuscany/sca-java-2.x/trunk/samples/launcher-shell/README
tuscany/sca-java-2.x/trunk/samples/launcher-shell/pom.xml
tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca (with props)
tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test
tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote
tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/
tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/
tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/
tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/
tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java
Added: tuscany/sca-java-2.x/trunk/samples/launcher-shell/README
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/samples/launcher-shell/README?rev=960122&view=auto
==============================================================================
--- tuscany/sca-java-2.x/trunk/samples/launcher-shell/README (added)
+++ tuscany/sca-java-2.x/trunk/samples/launcher-shell/README Fri Jul 2 22:02:39 2010
@@ -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
+
Added: tuscany/sca-java-2.x/trunk/samples/launcher-shell/pom.xml
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/samples/launcher-shell/pom.xml?rev=960122&view=auto
==============================================================================
--- tuscany/sca-java-2.x/trunk/samples/launcher-shell/pom.xml (added)
+++ tuscany/sca-java-2.x/trunk/samples/launcher-shell/pom.xml Fri Jul 2 22:02:39 2010
@@ -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>
Added: tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca?rev=960122&view=auto
==============================================================================
--- tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca (added)
+++ tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca Fri Jul 2 22:02:39 2010
@@ -0,0 +1,2 @@
+#!/bin/bash
+java -classpath `find target -name "*.jar" | awk '{ printf "%s:", $1 }'` sample.Shell
Propchange: tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca
------------------------------------------------------------------------------
svn:executable = *
Added: tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test?rev=960122&view=auto
==============================================================================
--- tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test (added)
+++ tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test Fri Jul 2 22:02:39 2010
@@ -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
Added: tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote?rev=960122&view=auto
==============================================================================
--- tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote (added)
+++ tuscany/sca-java-2.x/trunk/samples/launcher-shell/sca-test-remote Fri Jul 2 22:02:39 2010
@@ -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
Added: tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java?rev=960122&view=auto
==============================================================================
--- tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java (added)
+++ tuscany/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java Fri Jul 2 22:02:39 2010
@@ -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;
+ }
+}