storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [05/12] storm git commit: let ManualDRPC throw Exception
Date Wed, 09 Mar 2016 15:53:58 GMT
let ManualDRPC throw Exception


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8e350d1c
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8e350d1c
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8e350d1c

Branch: refs/heads/master
Commit: 8e350d1cf1f16b0101d699de0016bb762061f1e3
Parents: 802d28e
Author: xiaojian.fxj <xiaojian.fxj@alibaba-inc.com>
Authored: Fri Feb 26 22:59:02 2016 +0800
Committer: xiaojian.fxj <xiaojian.fxj@alibaba-inc.com>
Committed: Fri Feb 26 22:59:02 2016 +0800

----------------------------------------------------------------------
 .../src/jvm/org/apache/storm/starter/ManualDRPC.java              | 3 ++-
 storm-core/src/clj/org/apache/storm/daemon/drpc.clj               | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/8e350d1c/examples/storm-starter/src/jvm/org/apache/storm/starter/ManualDRPC.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/src/jvm/org/apache/storm/starter/ManualDRPC.java b/examples/storm-starter/src/jvm/org/apache/storm/starter/ManualDRPC.java
index 34136a1..f986c88 100644
--- a/examples/storm-starter/src/jvm/org/apache/storm/starter/ManualDRPC.java
+++ b/examples/storm-starter/src/jvm/org/apache/storm/starter/ManualDRPC.java
@@ -47,7 +47,7 @@ public class ManualDRPC {
 
     }
 
-    public static void main(String[] args) {
+    public static void main(String[] args) throws Exception{
         TopologyBuilder builder = new TopologyBuilder();
         LocalDRPC drpc = new LocalDRPC();
 
@@ -59,6 +59,7 @@ public class ManualDRPC {
         LocalCluster cluster = new LocalCluster();
         Config conf = new Config();
         cluster.submitTopology("exclaim", conf, builder.createTopology());
+
         System.out.println(drpc.execute("exclamation", "aaa"));
         System.out.println(drpc.execute("exclamation", "bbb"));
     }

http://git-wip-us.apache.org/repos/asf/storm/blob/8e350d1c/storm-core/src/clj/org/apache/storm/daemon/drpc.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/org/apache/storm/daemon/drpc.clj b/storm-core/src/clj/org/apache/storm/daemon/drpc.clj
index 2cb4016..a128972 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/drpc.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/drpc.clj
@@ -74,7 +74,7 @@
         (let [app (-> (webapp drpc-server http-creds-handler)
                     requests-middleware)]
           (.setHttpServlet drpc-server (ring.util.servlet/servlet app))))
-      (.launchServer drpc-server)))
+      (.launchServer drpc-server false conf)))
 )
 
 (defn -main []


Mime
View raw message