summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk
diff options
context:
space:
mode:
authorjsdelfino <jsdelfino@13f79535-47bb-0310-9956-ffa450edef68>2010-08-29 02:46:12 +0000
committerjsdelfino <jsdelfino@13f79535-47bb-0310-9956-ffa450edef68>2010-08-29 02:46:12 +0000
commit460613d0d5e60b9ed43094220b89dd31388463c2 (patch)
tree95e9e151a9fd7c59d1c013129866dd7733b2a529 /sca-java-2.x/trunk
parent551faa42eb014275324d9eddb6d88f83d4e93f30 (diff)
Minor change. Code format and cleanup.
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@990477 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/trunk')
-rw-r--r--sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/Shell.java102
-rw-r--r--sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/ShellServlet.java7
2 files changed, 62 insertions, 47 deletions
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
index 3c4d069c17..f2790409e9 100644
--- 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
@@ -24,23 +24,22 @@ import static java.lang.System.out;
import static java.util.Collections.emptyList;
import static java.util.Collections.singletonList;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.io.StringWriter;
+import java.util.ArrayList;
import java.util.Arrays;
+import java.util.HashMap;
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.PrintWriter;
-import java.io.StringWriter;
-import java.io.InputStreamReader;
-import java.io.OutputStreamWriter;
-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.
*/
@@ -71,9 +70,9 @@ public class Shell {
public Shell(NodeFactory nf) {
this.nodeFactory = nf;
}
-
+
List<?> start(final String name, final String curi, final String cloc) {
- if (nodes.containsKey(name))
+ if(nodes.containsKey(name))
return emptyList();
final Node node = nodeFactory.createNode(new Contribution(curi, cloc));
nodes.put(name, new NodeInfo(name, curi, cloc, node));
@@ -83,7 +82,7 @@ public class Shell {
List<?> stop(final String name) {
final NodeInfo ninfo = nodes.get(name);
- if (ninfo == null)
+ if(ninfo == null)
return emptyList();
ninfo.node.stop();
nodes.remove(name);
@@ -91,7 +90,7 @@ public class Shell {
}
List<?> stop() {
- for (NodeInfo ninfo: nodes.values())
+ for(NodeInfo ninfo: nodes.values())
ninfo.node.stop();
nodes.clear();
return emptyList();
@@ -103,7 +102,7 @@ public class Shell {
}
List<?> status() {
- return new ArrayList(nodes.values());
+ return new ArrayList<Object>(nodes.values());
}
List<?> history() {
@@ -117,40 +116,60 @@ public class Shell {
List<String> read(final BufferedReader r) throws IOException {
final String l = r.readLine();
history.add(l);
- return l != null? Arrays.asList(l.split(" ")) : singletonList("bye");
+ return l != null ? Arrays.asList(l.split(" ")) : singletonList("bye");
}
-
+
Callable<List<?>> eval(final List<String> toks) {
final String op = toks.get(0);
- if(op.equals("start")) return new Callable<List<?>>() { public List<?> call() {
- return start(toks.get(1), toks.get(2), toks.get(3));
- }};
- if(op.equals("stop")) return new Callable<List<?>>() { public List<?> call() {
- if (toks.size() == 1)
- return stop();
- return stop(toks.get(1));
- }};
- if(op.equals("restart")) return new Callable<List<?>>() { public List<?> call() {
- return restart(toks.get(1), toks.get(2), toks.get(3));
- }};
- if(op.equals("status")) return new Callable<List<?>>() { public List<?> call() {
- return status();
- }};
- if(op.equals("history")) return new Callable<List<?>>() { public List<?> call() {
- return history();
- }};
- if(op.equals("bye")) return new Callable<List<?>>() { public List<?> call() {
- return bye();
- }};
- return new Callable<List<?>>() { public List<?> call() {
- return emptyList();
- }};
+ if(op.equals("start"))
+ return new Callable<List<?>>() {
+ public List<?> call() {
+ return start(toks.get(1), toks.get(2), toks.get(3));
+ }
+ };
+ if(op.equals("stop"))
+ return new Callable<List<?>>() {
+ public List<?> call() {
+ if(toks.size() == 1)
+ return stop();
+ return stop(toks.get(1));
+ }
+ };
+ if(op.equals("restart"))
+ return new Callable<List<?>>() {
+ public List<?> call() {
+ return restart(toks.get(1), toks.get(2), toks.get(3));
+ }
+ };
+ if(op.equals("status"))
+ return new Callable<List<?>>() {
+ public List<?> call() {
+ return status();
+ }
+ };
+ if(op.equals("history"))
+ return new Callable<List<?>>() {
+ public List<?> call() {
+ return history();
+ }
+ };
+ if(op.equals("bye"))
+ return new Callable<List<?>>() {
+ public List<?> call() {
+ return bye();
+ }
+ };
+ return new Callable<List<?>>() {
+ public List<?> call() {
+ return emptyList();
+ }
+ };
}
List<?> apply(final Callable<List<?>> func) {
try {
return func.call();
- } catch (Exception e) {
+ } catch(Exception e) {
StringWriter sw = new StringWriter();
e.printStackTrace(new PrintWriter(sw));
return singletonList(sw);
@@ -166,7 +185,8 @@ public class Shell {
}
public Map<String, NodeInfo> run(final BufferedReader r, final PrintWriter w) throws IOException {
- while(print(apply(eval(read(r))), w));
+ while(print(apply(eval(read(r))), w))
+ ;
r.close();
return nodes;
}
diff --git a/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/ShellServlet.java b/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/ShellServlet.java
index 76c5758384..55aadbd09b 100644
--- a/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/ShellServlet.java
+++ b/sca-java-2.x/trunk/samples/launcher-shell/src/main/java/sample/ShellServlet.java
@@ -18,9 +18,8 @@
*/
package sample;
-import java.io.IOException;
-import java.io.Writer;
import java.io.BufferedReader;
+import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;
@@ -35,19 +34,15 @@ public class ShellServlet extends HttpServlet {
Shell shell;
- //@Override
public void init() {
shell = new Shell(WebAppHelper.getNodeFactory());
}
- //@Override
public void destroy() {
shell.stop();
}
- //@Override
protected void doGet(final HttpServletRequest req, final HttpServletResponse resp) throws IOException {
shell.run(new BufferedReader(new InputStreamReader(new URL(req.getParameter("conf")).openStream())), resp.getWriter());
}
}
-